public class RedisMessageStore extends AbstractKeyValueMessageStore implements BeanClassLoaderAware
MessageStore および MessageGroupStore の Redis 実装 MessageGroupStore.MessageGroupCallbackMESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIXlogger| コンストラクターと説明 |
|---|
RedisMessageStore(RedisConnectionFactory connectionFactory) 提供された RedisConnectionFactory とデフォルトの空のプレフィックスに基づいて RedisMessageStore を構築します。 |
RedisMessageStore(RedisConnectionFactory connectionFactory, StringSE prefix) 提供された RedisConnectionFactory とプレフィックスに基づいて RedisMessageStore を構築します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected CollectionSE<?> | doListKeys(StringSE keyPattern) |
protected ObjectSE | doRemove(ObjectSE id) |
protected void | doRemoveAll(CollectionSE<ObjectSE> ids) |
protected ObjectSE | doRetrieve(ObjectSE id) |
protected void | doStore(ObjectSE id, ObjectSE objectToStore) |
protected void | doStoreIfAbsent(ObjectSE id, ObjectSE objectToStore) |
void | setBeanClassLoader(ClassLoaderSE classLoader) |
void | setValueSerializer(RedisSerializer<?> valueSerializer) |
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupaddMessageToGroup, copy, expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdlegetRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizecloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEforEachSE, spliteratorSEpublic RedisMessageStore(RedisConnectionFactory connectionFactory)
RedisConnectionFactory とデフォルトの空のプレフィックスに基づいて RedisMessageStore を構築します。connectionFactory - 使用する RedisConnectionFactorypublic RedisMessageStore(RedisConnectionFactory connectionFactory, StringSE prefix)
RedisConnectionFactory とプレフィックスに基づいて RedisMessageStore を構築します。connectionFactory - 使用する RedisConnectionFactoryprefix - 使用するキープレフィックス。同じブローカーを複数のストアで使用できるようにします。AbstractKeyValueMessageStore.AbstractKeyValueMessageStore(String)public void setBeanClassLoader(ClassLoaderSE classLoader)
BeanClassLoaderAware の setBeanClassLoader public void setValueSerializer(RedisSerializer<?> valueSerializer)
protected ObjectSE doRetrieve(ObjectSE id)
AbstractKeyValueMessageStore の doRetrieve protected void doStore(ObjectSE id, ObjectSE objectToStore)
AbstractKeyValueMessageStore の doStore protected void doStoreIfAbsent(ObjectSE id, ObjectSE objectToStore)
AbstractKeyValueMessageStore の doStoreIfAbsent protected ObjectSE doRemove(ObjectSE id)
AbstractKeyValueMessageStore の doRemove protected void doRemoveAll(CollectionSE<ObjectSE> ids)
AbstractKeyValueMessageStore の doRemoveAll protected CollectionSE<?> doListKeys(StringSE keyPattern)
AbstractKeyValueMessageStore の doListKeys