136.4. キューコンシューマー – from(“hazelcast-queue:foo”)

キューコンシューマーには、次の 2 つの異なるモードがあります。

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!");