Hi, Does anyone use rabbitmq as a spout?
I just begin to use storm and I want to integrate it with rabbitmq. Can anyone provide a sample code to implement the backtype.storm.spout.Scheme to deserialize a RabbitMQ message payload? A simple example would be of great help. I am confused about this part. I am using json style message in my rabbitmq payload. Thanks. best, Yuheng
