Thank you. I have been walking through the material in https://github.com/ppat/storm-rabbitmq and I am not sure how to implement the "Scheme" class. I know I need a custom scheme to use RabbitMQSpout.
Can I use RabbitMQMessageScheme directly? Do I have to implement any functions in RabbitMQMessageScheme.java? Thanks for help. best, On Thu, Oct 30, 2014 at 11:54 AM, John Connolly <[email protected]> wrote: > 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 >
