The ZeroMQ binding can be combined with Ring Buffer Channels and the LMAX Disruptor to create low-latency processing engines. Consider the following topology where a consumer receives events from one channel, processes them and subsequently invokes another service that in turn publishes output to a second channel:
The above topology is configured to use ring buffer channels as follows:
If the two channels
In this model, messages are read from a ZeroMQ socket on a thread and placed in a ring buffer slot
Add Comment