switch to amqp-stream