136.4. キューコンシューマー – from(“hazelcast-queue:foo”)
キューコンシューマーには、次の 2 つの異なるモードがあります。
- Poll
- Listen
Poll モードのサンプル
fromF("hazelcast-%sfoo?queueConsumerMode=Poll", HazelcastConstants.QUEUE_PREFIX)).to("mock:result");このようにして、コンシューマーはキューをポーリングし、タイムアウト後にキューの先頭または null を返します。
代わりに Listen モードでは、コンシューマーはキューのイベントをリッスンします。
Listen モードのキューコンシューマーは、次の 2 つの操作を提供します: * 追加 * 削除
Listen モードのサンプル
fromF("hazelcast-%smm", HazelcastConstants.QUEUE_PREFIX)
.log("object...")
.choice()
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ADDED))
.log("...added")
.to("mock:added")
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.REMOVED))
.log("...removed")
.to("mock:removed")
.otherwise()
.log("fail!");