THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The topic producer provides only one operarion operation (publish).
Sample for
...
publish:
Code Block |
---|
from("direct:add") .setHeader(HazelcastConstants.OPERATION, constant(HazelcastConstants.ADDPUBLISH_OPERATION)) .toF("hazelcast:%sbar", HazelcastConstants.QUEUEPUBLISH_PREFIXOPERATION); |
...
Topic consumer – from(“hazelcast:topic:foo”)
The topic consumer provides only one operation (received). This component is supposed to support multiple consumption as it's expected when it comes to topics so you are free to have as much consumers as you need on the same hazelcast topic.
Code Block |
---|
fromF("hazelcast:%sfoo", HazelcastConstants.TOPIC_PREFIX)
.choice()
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.RECEIVED))
.log("...message received")
.otherwise()
.log("...this should never have happened") |
Anchor | ||||
---|---|---|---|---|
|
Usage of List
...
The list producer provides 4 operations (add, set, get, removevalue).
Sample for add:
Code Block |
---|
from("direct:add") .setHeader(HazelcastConstants.OPERATION, constant(HazelcastConstants.ADD_OPERATION)) .toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX); |
...