wiring up with spark_amqp_session