RabbitMQ bolt not sending publish request

[andreimaximov]

Using the RabbitMQSpout successfully but cannot get the RabbitMQBolt (sink) to work. I am using the exact the same ConnectionConfig 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 my TupleToMessageNonDynamic implementation.

Dependencies:

org.apache.storm, storm-core, 0.9.4
io.latent, storm-rabbitmq, 0.6.1
com.typesafe, config, 1.2.1

[ppat]

Do you have gist with some code demonstrating the problem?

[chen116]

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!