Reliable Topic Connector
Reliable Topic provides a simple pub/sub messaging API which can be used as a data sink within a pipeline.
The map connector is included in the full and slim distributions of Hazelcast.
hz.getReliableTopic("topic") .addMessageListener(message -> System.out.println(message)); Pipeline p = Pipeline.create(); p.readFrom(TestSources.itemStream(100)) .withIngestionTimestamps() .writeTo(Sinks.reliableTopic("topic"));
A simple example is supplied above. For a more advanced version, also see Observables.