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, setTimeoutOnIdlegetRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizecloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEgetMessageGroup, pollMessageFromGroupforEachSE, spliteratorSEprotected 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 BeansExceptionprotected 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)
BasicMessageGroupStoreBasicMessageGroupStore 内の removeMessageGroup groupId - 削除するグループの ID。public int messageGroupSize(ObjectSE groupId)
BasicMessageGroupStoreBasicMessageGroupStore 内の 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)
MessageGroupStoreMessageGroupStore 内の removeMessagesFromGroup key - メッセージを含むグループの groupId。messages - 削除するメッセージ。public void setLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber)
MessageGroupStoreMessageGroupStore 内の setLastReleasedSequenceNumberForGroup groupId - グループ識別子。sequenceNumber - シーケンス番号。public IteratorSE<MessageGroup> iterator()
IterableSE<MessageGroup> 内の iteratorSE MessageGroupStore 内の iterator MessageGroup の反復子。public void completeGroup(ObjectSE groupId)
MessageGroupStoreMessageGroupStore 内の completeGroup groupId - グループ識別子。public Message<?> getOneMessageFromGroup(ObjectSE groupId)
MessageGroupStoreMessageGroup から 1 つの Message を返します。MessageGroupStore 内の getOneMessageFromGroup groupId - グループ識別子。Messagepublic void addMessagesToGroup(ObjectSE groupId, Message<?>... messages)
MessageGroupStoreMessageGroupStore 内の addMessagesToGroup groupId - メッセージを保存するグループ ID。messages - 追加するメッセージ。public CollectionSE<Message<?>> getMessagesForGroup(ObjectSE groupId)
MessageGroupStoreMessageGroupStore 内の getMessagesForGroup groupId - メッセージを取得するグループ ID。