3.3. リスナーおよび通知

単一ノードでキャッシュイベントをリッスンすることが望ましい場合は、クラスターリスナーを使用する必要があります。

そのために必要なのは、リスナーがクラスター化されているというアノテーションを付けるよう設定することだけです。

@Listener (clustered = true)
public class MyClusterListener { .... }

@Listener (clustered = true)
public class MyClusterListener { .... }

クラスター化されていないリスナーからのクラスターリスナーには、いくつかの制限があります。

リスナーがインストールされているノードで適用可能なすべてのイベントがリスナーに発生します。KeyFilter （キーのフィルタリングのみ）または CacheEventFilter （キーのフィルタリングのみを許可する）を使用して、発生したイベントを動的にフィルターすることができます（キー、古いメタデータ、新しい値、新しいメタデータのフィルターに使用され、イベントがイベントの前にある場合(ie. isPre)、コマンドタイプなど、新しいメタデータのフィルターに使用されます。

この例で、イベントがキーOnly Meのエントリーを変更したときにイベントのみを発生させる単純なKeyFilterを示しています。

public class SpecificKeyFilter implements KeyFilter<String> {
    private final String keyToAccept;

    public SpecificKeyFilter(String keyToAccept) {
      if (keyToAccept == null) {
        throw new NullPointerException();
      }
      this.keyToAccept = keyToAccept;
    }

    boolean accept(String key) {
      return keyToAccept.equals(key);
    }
}

...
cache.addListener(listener, new SpecificKeyFilter("Only Me"));
...

public class SpecificKeyFilter implements KeyFilter<String> {
    private final String keyToAccept;

    public SpecificKeyFilter(String keyToAccept) {
      if (keyToAccept == null) {
        throw new NullPointerException();
      }
      this.keyToAccept = keyToAccept;
    }

    boolean accept(String key) {
      return keyToAccept.equals(key);
    }
}

...
cache.addListener(listener, new SpecificKeyFilter("Only Me"));
...

これは、より効率的な方法で受信するイベントを制限したい場合に便利です。

また、イベントを発生させする前に別の値に値を変換できる CacheEventConverter を指定することもできます。これは、値の変換を行うコードをモジュール化するのに適しています。

リスナーがインストールされると、完全にインストールされた後にのみイベントが通知されます。

リスナーの初回登録時にキャッシュコンテンツの現在の状態を取得することが望ましい場合があります。この場合、キャッシュ内の各要素の @CacheEntryCreated タイプのイベントが生成されます。この最初のフェーズで追加で生成されたイベントは、適切なイベントが発生するまでキューに置かれます。

トランザクションではないキャッシュで、重複したイベントを受け取ることが可能です。これは、putなどの書き込み操作の実行中に、キーのプライマリー所有者がダウンした場合に可能になります。

Red Hat Data Grid は、内部で put 操作を指定のキーの新しいプライマリー所有者に送信することで認識します。ただし、書き込みが最初にバックアップに複製されたかどうかについては保証はありません。そのため、CacheEntryCreatedEvent、CacheEntryModifiedEvent、およびCacheEntryRemovedEventの書き込みイベントの 1 つ以上が、1 つの操作で送信される可能性があります。

複数のイベントが生成されると、Red Hat Data Grid はretried コマンドで生成されたイベントを示し、変更の表示に注意せずにこの状況を把握できるようにします。

@Listener
public class MyRetryListener {
  @CacheEntryModified
  public void entryModified(CacheEntryModifiedEvent event) {
    if (event.isCommandRetried()) {
      // Do something
    }
  }
}

@Listener
public class MyRetryListener {
  @CacheEntryModified
  public void entryModified(CacheEntryModifiedEvent event) {
    if (event.isCommandRetried()) {
      // Do something
    }
  }
}

また、CacheEventFilter または CacheEventConverter を使用する場合は、EventType にメソッド isRetry が含まれ、再試行のためにイベントが生成されたかどうかを指示します。