Processing Rabbitmq's Stream with "Apache Flink"

Read about it here: http://shekharsingh.com/apache-flink-rabbimq-streams-processor.html

Execute using (Make sure flink & rabbitmq is up and running):

flink run -c com.rootcss.flink.RabbitmqStreamProcessor target/flink-rabbitmq-0.1.jar

Build using:

mvn clean package

Logs at:

tail -f $FLINK_HOME/log/*

Open Dashboard:

http://localhost:8081/

Other commands:

flink run -c com.rootcss.flink.RabbitmqWindowStreamProcessor target/flink-rabbitmq-0.1.jar --output /Users/rootcss/output.out --window 10
flink run -c com.rootcss.flink.RabbitmqMessageRateCalculator target/flink-rabbitmq-0.1.jar --output /Users/rootcss/output2.out