I'd recommend making use of a spout that others have already built and battle tested. A quick google search shows several including this one: https://github.com/ppat/storm-rabbitmq
Unless you have a very special use case, I'm not sure re-inventing the wheel is worth the time and effort. Stephen On Tue, Sep 29, 2015 at 1:39 AM, Ankur Garg <[email protected]> wrote: > Hi, > > I want to consume the messages in my Storm Spout from a rabbitMq Queue. > > Now , we are using Spring AMQP to send and receive messages from RabbitMq > asynchronously. > > Spring AMQP provides mechanism(either creating a listener or using > annotation @RabbitListner) to read message from the queue aysnchronously. > > The problem is I can have a Listener to read the message from the Queue. > But how do I send this message to my Storm Spout which is running on storm > cluster ? > > The topology will start a cluster, but in my nextTuple() method of my > spout , I need to read message from this Queue. Can Spring AMQP be used > here ? > > I have a listener configured to read message from the queue: > > @RabbitListener(queues = "queueName") > public void processMessage(QueueMessage message) { > > } > > How can the above message received at the listener be sent to my spout > running on a cluster . > > Alternatively , how can a spout's nextTuple() method have this method > inside it ? Is it possible > > Is there any integration there between Spring AMQP and Storm? > > > Thanks > > Ankur > > > >
