There are two Java classes. example.Listener and example.Publisher. They are designed to exchange messages using either a Queue or a Topic (pub/sub). To take full advantage of the example launch at ...

For the Tests I have implemented Apache Kafka as of now, which later can be replaced with other Queue Providers like Apache ActiveMQ, Apache Apollo, etc. To run the ...