Set of projects containing spouts, bolts, clients, etc. to use Storm with Rabbitmq and JSON
storm-rabbitmq-test: This toplogy consumes tuples from storm-amqp-spout. To generate petitions a java client is used.
dependencies:
- https://github.com/davidpr/storm-amqp-spout
- https://github.com/davidpr/storm-rabbitmq/tree/master/storm-rabbitmq-client-test
storm-rabbitmq-json-test: This toplogy also consumes tuples from strom-amqp-spout, however, the client generates petitions using JSON class
dependecies:
- https://github.com/davidpr/storm-amqp-spout
- https://github.com/davidpr/storm-rabbitmq/tree/master/storm-client-json
- https://github.com/davidpr/storm-json
storm-rabbitmq-rpc-json-test: This topology consumes tuples from storm-amqp-spout-rpc, additionaly, the spout uses Rabbitmq RPC functionality. Here the spout creates a response queue in which it delivers responses via RPC.
dependencies:
- https://github.com/davidpr/storm-rabbitmq/tree/master/storm-amqp-spout-rpc
- https://github.com/davidpr/storm-rabbitmq/tree/master/storm-client-rpc-json
- https://github.com/davidpr/storm-json
storm-rabbitmq-kyo-rpc-json-test: This topology consumes tuples from storm-amqp-spout-bridge. The point is that this spout is esentially the same as the storm-amqp-spout becuase is this topology it is the bolt the responsible for answering via RPC insted of the bolt. However, this spout needs to pass down to the bolt some extra information, so responses are matched with requests. This topology uses Kryo serialization.
dependencies:
- https://github.com/davidpr/storm-rabbitmq/tree/master/storm-amqp-spout-bridge
- https://github.com/davidpr/storm-rabbitmq/tree/master/storm-client-rpc-json
- https://github.com/davidpr/storm-json
storm-amqp-spout-rpc: This spout answers petitions form clients via RPC.
storm-amqp-spout-bridge: This spout doens't answer petitions from client via RPC but it passes down RPC related information to bolt so the latest one can answer via RPC.
storm-rabbitmq-client-test: This client sends a request to and AMQP spout.
storm-client-json: This client sends a request to a AMQP spout using JSON class.
storm-client-rpc-json: This client sends a request to a AMQP spout using request and waits until some AMQP answer queue has the RPC response.