Open andreimaximov opened 9 years ago
Do you have gist with some code demonstrating the problem?
I had similar problem. For some reason my rabbitmq bolt will not send if exchange is set to '', if I change the exchange to some other value, and bind to the queue, then it works!
Using the
RabbitMQSpout
successfully but cannot get theRabbitMQBolt
(sink) to work. I am using the exact the sameConnectionConfig
for both.The RabbitMQ management console shows the
RabbitMQBolt
connecting successfully, but the target queue is not filling up and the RabbitMQ tracer is not detecting the bolt sending any publish requests.I have verified that the bolt is receiving tuples by debugging the
extractBody
method of myTupleToMessageNonDynamic
implementation.Dependencies: