Now that we have installed Storm, the next step will be to integrate RabbitMQ with Storm, for which we will have to create a custom spout called the RabbitMQ spout. This spout will read the messages from the specified queue; thus, it will furnish the role of a consumer, and then push these messages to a downstream topology.
Here is how the spout code will look:
public class AMQPRecvSpout implements IRichSpout{
//The constructor where we set initialize all properties
public AMQPRecvSpout(String host, int port, String username, String password, String vhost, boolean requeueOnFail, boolean autoAck) {
this.amqpHost = host;
this.amqpPort = port;
this.amqpUsername = username;
this.amqpPasswd = password;
this.amqpVhost = vhost;
this.requeueOnFail = requeueOnFail;
this.autoAck = autoAck;
}
/*
Open method of the spout , here we initialize the prefetch count , this parameter specified how many messages would be prefetched from the...