We use rabbitmq as a source for spouts pretty extensively. Have a look at https://github.com/ppat/storm-rabbitmq
On Thu, Oct 30, 2014 at 10:33 AM, Yuheng Du <[email protected]> wrote: > 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 > -- John Connolly Software Engineer twitter.com/johnconnolly foobarmustache.tumblr.com
