126.3. map cache consumer - from("hazelcast-map:foo")


Hazelcast は、データ収集でイベントリスナーを提供します。キャッシュが操作される際に通知する場合には、マップコンシューマーを使用できます。4 つのイベントがあります updatedelete、および envict です。イベントタイプは、hazelcast.listener.action" ヘッダー変数に保存されます。マップコンシューマーは、これらの変数内にいくつかの追加情報を提供します。

レスポンスメッセージ内のヘッダー変数:

Nameタイプ説明

CamelHazelcastListenerTime

Long

イベントの時間(ミリ秒単位)

CamelHazelcastListenerType

文字列

マップコンシューマーは「cachelistener」に設定します。

CamelHazelcastListenerAction

文字列

イベントのタイプ: ここでは、が 追加 され、更新 され、envicted、および removed が削除されます。

CamelHazelcastObjectId

文字列

オブジェクトの oid

CamelHazelcastCacheName

文字列

キャッシュの名前 - 例:「foo」

CamelHazelcastCacheType

文字列

キャッシュのタイプ(ここではマップ)

オブジェクト値は、メッセージボディー内で put および update アクション内に保存されます。

以下に例を示します。

Copy to Clipboard Toggle word wrap
fromF("hazelcast-%sfoo", HazelcastConstants.MAP_PREFIX)
.log("object...")
.choice()
    .when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ADDED))
         .log("...added")
         .to("mock:added")
    .when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ENVICTED))
         .log("...envicted")
         .to("mock:envicted")
    .when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.UPDATED))
         .log("...updated")
         .to("mock:updated")
    .when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.REMOVED))
         .log("...removed")
         .to("mock:removed")
    .otherwise()
         .log("fail!");
トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat, Inc.