storm-rabbitmq
storm-rabbitmq copied to clipboard
ppat
A library of tools for interacting with RabbitMQ from Storm.
Using the `RabbitMQSpout` successfully but cannot get the `RabbitMQBolt` (sink) to work. I am using the exact the same `ConnectionConfig` for both. The RabbitMQ management console shows the `RabbitMQBolt` connecting...
Upgrade storm-core to 1.1.1 and amqp-client to 5.0.0
Currently, if I specify the Rabbit Host Parts via topology config, I get a a NPE when it is trying to configure the connection. It looks up HA Hosts and...
In trying to setup a spout that does not use HA, the code for checking for HA throws a NPE in this code here since it assumes that any key...
Change that allows the configuration of a KeyStore and a TrustStore to be used when using SSL certificates (fixes an open issue)
Kindly let me know your thoughts and if any changes needed, I have used the below code as reference. https://github.com/ptgoetz/storm-jms/tree/master/src/main/java/org/apache/storm/jms/trident
Would like to output tuples on multiple streams for the same incoming message, instead of one or the other via a split with MultiStreamSpout.
