public abstract class AbstractConfigurableMongoDbMessageStore extends AbstractMessageGroupStore implements InitializingBean, ApplicationContextAware
AbstractMessageGroupStore
実装。MessageGroupStore.MessageGroupCallback
修飾子と型 | フィールドと説明 |
---|---|
protected StringSE | collectionName |
protected Log | logger |
protected MongoDatabaseFactory | mongoDbFactory |
static StringSE | SEQUENCE_NAME |
コンストラクターと説明 |
---|
AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter, StringSE collectionName) |
AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, StringSE collectionName) |
AbstractConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate, StringSE collectionName) |
addMessageToGroup, copy, expireMessageGroups, getGroupMetadata, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdle
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSize
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
getMessageGroup, pollMessageFromGroup
forEachSE, spliteratorSE
protected final Log logger
protected final StringSE collectionName
protected final MongoDatabaseFactory mongoDbFactory
public AbstractConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate, StringSE collectionName)
public AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, StringSE collectionName)
public AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter, StringSE collectionName)
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
ApplicationContextAware
の setApplicationContext
BeansException
protected MongoTemplate getMongoTemplate()
protected MappingMongoConverter getMappingMongoConverter()
protected ApplicationContext getApplicationContext()
protected MessageBuilderFactory getMessageBuilderFactory()
public void afterPropertiesSet()
InitializingBean
の afterPropertiesSet
public MessageMetadata getMessageMetadata(UUIDSE id)
public void removeMessageGroup(ObjectSE groupId)
BasicMessageGroupStore
BasicMessageGroupStore
の removeMessageGroup
groupId
- 削除するグループの ID。public int messageGroupSize(ObjectSE groupId)
BasicMessageGroupStore
BasicMessageGroupStore
の messageGroupSize
groupId
- グループ識別子。protected long getNextId()
MessageDocument
sequence
を含むドキュメントに対して MongoDB INC
操作を実行し、新しい MessageDocument
の新しい増分値を返します。SEQUENCE_NAME
ドキュメントはオンデマンドで作成されます。protected void addMessageDocument(MessageDocument document)
public void removeMessagesFromGroup(ObjectSE key, CollectionSE<Message<?>> messages)
MessageGroupStore
MessageGroupStore
の removeMessagesFromGroup
key
- メッセージを含むグループの groupId。messages
- 削除するメッセージ。public void setLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber)
MessageGroupStore
MessageGroupStore
の setLastReleasedSequenceNumberForGroup
groupId
- グループ識別子。sequenceNumber
- シーケンス番号。public IteratorSE<MessageGroup> iterator()
IterableSE<MessageGroup>
の iteratorSE
MessageGroupStore
の iterator
MessageGroup
の反復子。public void completeGroup(ObjectSE groupId)
MessageGroupStore
MessageGroupStore
の completeGroup
groupId
- グループ識別子。public Message<?> getOneMessageFromGroup(ObjectSE groupId)
MessageGroupStore
MessageGroup
から 1 つの Message
を返します。MessageGroupStore
の getOneMessageFromGroup
groupId
- グループ識別子。Message
public void addMessagesToGroup(ObjectSE groupId, Message<?>... messages)
MessageGroupStore
MessageGroupStore
の addMessagesToGroup
groupId
- メッセージを保存するグループ ID。messages
- 追加するメッセージ。public CollectionSE<Message<?>> getMessagesForGroup(ObjectSE groupId)
MessageGroupStore
MessageGroupStore
の getMessagesForGroup
groupId
- メッセージを取得するグループ ID。