org.springframework.integration.redis.store.RedisMessageStore

実装済みのインターフェース一覧:: IterableSE<MessageGroup>、Aware、BeanClassLoaderAware、IntegrationPattern、BasicMessageGroupStore、MessageGroupStore、MessageStore

public class RedisMessageStore extends AbstractKeyValueMessageStore implements BeanClassLoaderAware

キー / 値スタイル MessageStore および MessageGroupStore の Redis 実装

導入:: 2.1
作成者:: Oleg Zhurakousky, Gary Russell, Artem Bilan, Michal Domagala, Yordan Tsintsov

ネストされたクラスの概要
インターフェース org.springframework.integration.store.MessageGroupStore から継承されたネストクラス / インターフェース
MessageGroupStore.MessageGroupCallback
フィールド概要
クラス org.springframework.integration.store.AbstractKeyValueMessageStore から継承されたフィールド
MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX
クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたフィールド
INTERRUPTED_WHILE_OBTAINING_LOCK, logger
コンストラクター概要
コンストラクター
コンストラクター
説明
RedisMessageStore(RedisConnectionFactory connectionFactory)
提供された RedisConnectionFactory とデフォルトの空のプレフィックスに基づいて RedisMessageStore を構築します。
RedisMessageStore(RedisConnectionFactory connectionFactory, StringSE prefix)
提供された RedisConnectionFactory とプレフィックスに基づいて RedisMessageStore を構築します。
方法の概要
修飾子と型
メソッド
説明
protected CollectionSE<?>
doListKeys(StringSE keyPattern)
protected @Nullable ObjectSE
doRemove(ObjectSE id)
protected void
doRemoveAll(CollectionSE<ObjectSE> ids)
protected @Nullable ObjectSE
doRetrieve(ObjectSE id)
protected void
doStore(ObjectSE id, ObjectSE objectToStore)
protected void
doStoreIfAbsent(ObjectSE id, ObjectSE objectToStore)
void
setBeanClassLoader(ClassLoaderSE classLoader)
void
setUseUnlink(boolean useUnlink)
ストアからメッセージを削除する際に使用する削除戦略を設定します。
void
setValueSerializer(RedisSerializer<?> valueSerializer)
クラス org.springframework.integration.store.AbstractKeyValueMessageStore から継承されたメソッド
addMessage, doAddMessage, doAddMessage, doAddMessagesToGroup, doCompleteGroup, doPollMessageFromGroup, doRemoveMessageFromGroupById, doRemoveMessageGroup, doRemoveMessagesFromGroup, doSetGroupCondition, doSetLastReleasedSequenceNumberForGroup, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageFromGroup, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, removeMessage, streamMessagesForGroup
クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたメソッド
addMessagesToGroup, addMessageToGroup, completeGroup, copy, executeLocked, executeLocked, expireMessageGroups, getLockRegistry, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, pollMessageFromGroup, registerMessageGroupExpiryCallback, removeMessageFromGroupById, removeMessageGroup, removeMessagesFromGroup, removeMessagesFromGroup, setExpiryCallbacks, setGroupCondition, setLastReleasedSequenceNumberForGroup, setLazyLoadMessageGroups, setLockRegistry, setTimeoutOnIdle
クラス org.springframework.integration.store.AbstractBatchingMessageGroupStore から継承されたメソッド
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSize
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース java.lang.IterableSE から継承されたメソッド
forEachSE, spliterator
インターフェース org.springframework.integration.store.MessageStore から継承されたメソッド
getIntegrationPatternType

コンストラクターの詳細
- RedisMessageStore
  public RedisMessageStore(RedisConnectionFactory connectionFactory)
  提供された RedisConnectionFactory とデフォルトの空のプレフィックスに基づいて RedisMessageStore を構築します。
  パラメーター:
  connectionFactory - 使用する RedisConnectionFactory
- RedisMessageStore
  public RedisMessageStore(RedisConnectionFactory connectionFactory, StringSE prefix)
  提供された RedisConnectionFactory とプレフィックスに基づいて RedisMessageStore を構築します。
  パラメーター:
  connectionFactory - 使用する RedisConnectionFactory
  prefix - 使用するキープレフィックス。同じブローカーを複数のストアで使用できるようにします。
  導入:
  4.3.12
  関連事項:
  AbstractKeyValueMessageStore(String)
方法の詳細
- 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

クラス RedisMessageStore

ネストされたクラスの概要

インターフェース org.springframework.integration.store.MessageGroupStore から継承されたネストクラス / インターフェース

フィールド概要

クラス org.springframework.integration.store.AbstractKeyValueMessageStore から継承されたフィールド

クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたフィールド

コンストラクター概要

方法の概要

クラス org.springframework.integration.store.AbstractKeyValueMessageStore から継承されたメソッド

クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたメソッド

クラス org.springframework.integration.store.AbstractBatchingMessageGroupStore から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース java.lang.IterableSE から継承されたメソッド

インターフェース org.springframework.integration.store.MessageStore から継承されたメソッド

コンストラクターの詳細

RedisMessageStore

RedisMessageStore

方法の詳細

setBeanClassLoader

setValueSerializer

setUseUnlink

doRetrieve

doStore

doStoreIfAbsent

doRemove

doRemoveAll

doListKeys