...
| Code Block | ||||
|---|---|---|---|---|
| ||||
<composite name="ProducerComposite" ...> <component name="TestProducer"> <implementation.java class="..."/> <producer name="channel" target="TestChannel"/> </component> </composite> <composite name="ChannelComposite"...> <channel name="TestChannel"> <f3:binding.zeromq/> </channel> </composite> <composite name="ConsumerComposite" ...> <component name="TestConsumer"> <implementation.java class="..."/> <consumer name="channel" source="TestChannel"/> </component> </composite> |
...
Consuming External Event Streams
The ZeroMQ binding can be used to connect a channel to an external event stream published by one or more external event sources:
To bind a channel to an external source, the ZeroMQ binding is configured with the IP address and port of the event source socket. If more than one source publishes events, multiple addresses can be specified as a space-delimited list:
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
<composite ...>
<channel name="TestChannel">
<f3:binding.zeromq addresses="192.0.2.1:12001 192.0.2.2:12001""/>
</channel>
<component name="TestConsumer">
<implementation.java class="..."/>
<consumer name="channel" source="TestChannel"/>
</component>
</composite>
|
Publishing to External Event Streams