問題タブ [spring-data-gemfire]

Spring のドキュメントによると、REST エンドポイントを使用する場合、Spring Session は Redis を透過的に活用して Web アプリケーションの HttpSession をサポートできるとのことです。

Web アプリケーションの HttpSession をサポートするために、Spring が Redis の代わりにこの場所で GemFire をサポートしているかどうかを知っている人はいますか?

参照: http://docs.spring.io/spring-session/docs/current/reference/html5/guides/rest.html

このようなクエリがあり、期待どおりに機能しません。かなりの数のバリエーションを試しましたが、クエリで何かが欠けています。

リポジトリ コード:

モデル:

私が得るスタックは次のようになります。

何が間違っているのかわかりません。どんな助けでも大歓迎です。

payloadgemfire キャッシュに送信しようとしています。payloadこれを MQ メッセージとして受け取ります。myoutbound adapterが another の場合は正常に動作しQueueます。

ただし、送信チャネルが Gemfire の送信アダプターである場合、例外がスローされます。以下はコードスニペットです。

ここで助けていただければ幸いです。私はGemfire + Spring IOが初めてなので

以下は、アプリケーションでメッセージを受信したときに表示されるエラーです

上のpayload行にここに出力されます..そして下の行はエラーです

「Spring Data」の目的を理解しようとしているときに、この記事に出くわし、Gemfire/Redis リポジトリとそれに対応する Spring-Data コンポーネントを使用していくつかの例を試しました。誰かが次の質問を手伝ってくれませんか。

シナリオ: GemFire が私のデータストアだったとき、CRUD 操作を実行するために、GemFireTemplate でメソッドcreate、get、removeを使用する必要がありました。Redis が私のデータストアだったとき、RedisTemplate でメソッド.opsForHash().put 、 .opsForHash().get 、および .opsForHash().deleteを使用して、同じ CRUD 操作を実行する必要がありました。

質問:

Spring-Data は、基礎となるデータ ストアに一定レベルの抽象化を提供することになっていませんか? それぞれの CRUD メソッドを知っていて、基礎となるデータ ストアに基づいて異なる API を持っていることが期待される場合、Spring-Data コンポーネントはどのような抽象化をもたらしますか? Gemfire 用の Jedis または Java クライアントを直接使用して、これらのデータストア固有の CRUD 操作を実行することはできませんか?

このリンクはそれを説明しているようですが、それを理解するには助けが必要なようです。

すべての永続ストアに対する一般的な API はありません。違いはあまりにも根本的です。ただし、Spring Data プロジェクトは、データにアクセスするための共通のプログラミング モデルを提供します。

Gemfire を使用してセッションを保存する Web アプリケーション (Spring Session - HTTPSession の実装) では、Gemfire は変更 (キャッシュの有効期限、キャッシュの変更、キャッシュの破棄など) をどのように通知しますか? 特に、Gemfire がクライアント サーバー モデルまたはピア ツー ピア モデルで展開されている場合などです。イベントは、分散環境全体のいずれかのノードでトリガーされる可能性があり、すべてのノードをリッスンし続けたくない場合があります..

Gemfire には通知を発行する MBean がありますが、アプリケーションをこれらの MBean 通知にリスナーをフックする必要がありますか、それとも他に良い方法がありますか?

目的は、そのようなイベント中にいくつかのクリーンアップ コードを配置することです。

ここで何をする必要があるかを理解するのに役立つ例を見つけることができなかったので、私の問題を説明します:

Pivotal の Gemfire 製品のカスタム リスナーを実装する Java Bean があります。次のようにメソッドを定義する CqListener と呼ばれるインターフェイスを実装します。

基本的に、Gemfire グリッドで連続クエリ (CQ) を実行すると、この Bean をリスナーとして登録し、クエリに一致するグリッド内の変更を受け取ります。

たとえば、次のような CQ を実行します。

「table_name」テーブル（Gemfireではリージョンと呼ばれます）の何かが変更されるたびCQEventに、メソッドに aが表示されます（CRUD）onEvent

私が今やろうとしているのは、Camel を配線して、この基礎となる CQ のものからカスタム ルートに何かをルーティングすることです。とにかく、Camelに「onEventへの呼び出しが行われたときはいつでも、それを取り、別の場所にルーティングしてください」と言うことができますか?

私がルーティングしようとしている別の場所は、Akka Actor です。akka と camel ( http://doc.akka.io/docs/akka/snapshot/scala/camel.html ) をラップするプロジェクトは既にありますが、インバウンド CQ イベントを取得するためのこのエンドポイント URI ビジネスを理解できません。 .

Camel に関する概念的なキーが不足していることはわかっているので、どんな助けも大歓迎です。jmsエンドポイントを使用してこれを実装することができたので、よく知られているプロトコルでどのように機能するかを理解しましたが、実装が私から離れて抽象化されているカスタムプロトコルでこれを行う方法を理解しようとしています(そのままです) CQListenerの場合）