クラス RedisMessageStore

方法の詳細

• setBeanClassLoader

  public void setBeanClassLoader(ClassLoaderSE classLoader)

  次で指定:

  インターフェース BeanClassLoaderAware 内の setBeanClassLoader 

• setValueSerializer

  public void setValueSerializer(RedisSerializer<?> valueSerializer)

• setUseUnlink

  public void setUseUnlink(boolean useUnlink)

  ストアからメッセージを削除する際に使用する削除戦略を設定します。

  デフォルトでは（false）、ストアは Redis GETDEL コマンドを使用します（Redis 6.2 以降）。

  true に設定すると、ストアは GET + UNLINK を使用します。

  このオプションを有効にすることを検討すべきケースは以下のとおりです。

  • 保存されるメッセージは大きく、削除をブロックすると Redis の遅延が顕著になる。
  • ユースケースでは、取得と削除の間のアトミック性は必要ありません。

  メモ: 値が小さい場合、Redis は UNLINK と同期削除を実行する可能性があるため、その利点は主にペイロードが大きい場合に発揮されます。

  パラメーター:

  useUnlink - 削除戦略を設定するためのパラメーター。

  導入:

  7.1

  関連事項:

  • GETDEL コマンド
  • UNLINK コマンド

• doRetrieve

  protected @Nullable ObjectSE doRetrieve(ObjectSE id)

  次で指定:

  クラス AbstractKeyValueMessageStore の doRetrieve 

• doStore

  protected void doStore(ObjectSE id, ObjectSE objectToStore)

  次で指定:

  クラス AbstractKeyValueMessageStore の doStore 

• doStoreIfAbsent

  protected void doStoreIfAbsent(ObjectSE id, ObjectSE objectToStore)

  次で指定:

  クラス AbstractKeyValueMessageStore の doStoreIfAbsent 

• doRemove

  protected @Nullable ObjectSE doRemove(ObjectSE id)

  次で指定:

  クラス AbstractKeyValueMessageStore の doRemove 

• doRemoveAll

  protected void doRemoveAll(CollectionSE<ObjectSE> ids)

  次で指定:

  クラス AbstractKeyValueMessageStore の doRemoveAll 

• doListKeys

  protected CollectionSE<?> doListKeys(StringSE keyPattern)

  次で指定:

  クラス AbstractKeyValueMessageStore の doListKeys