org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore

実装されているすべてのインターフェース:: IterableSE<MessageGroup>、Aware、InitializingBean、ApplicationContextAware、BasicMessageGroupStore、MessageGroupStore

既知の直属サブクラス: ConfigurableMongoDbMessageStore, MongoDbChannelMessageStore

public abstract class AbstractConfigurableMongoDbMessageStore extends AbstractMessageGroupStore implements InitializingBean, ApplicationContextAware

このクラスの実装の一般的なオプションの構成を提供するための、抽象的な MongoDB AbstractMessageGroupStore 実装。

導入:: 4.0
作成者:: Artem Bilan, Adama Sorho, Youbin Wu

ネストされたクラスの要約
インターフェース org.springframework.integration.store.MessageGroupStore から継承されたネストクラス / インターフェース
MessageGroupStore.MessageGroupCallback
フィールドのサマリー
フィールド
修飾子と型
フィールド
説明
protected final StringSE
collectionName
protected final Log
logger
protected final MongoDatabaseFactory
mongoDbFactory
static final StringSE
SEQUENCE_NAME
クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたフィールド
GROUP_ID_MUST_NOT_BE_NULL, INTERRUPTED_WHILE_OBTAINING_LOCK
コンストラクターの概要
コンストラクター
コンストラクター
説明
AbstractConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate, StringSE collectionName)
AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, StringSE collectionName)
AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter, StringSE collectionName)
メソッドのサマリー
修飾子と型
メソッド
説明
protected void
addMessageDocument(MessageDocument document)
void
afterPropertiesSet()
protected void
createIndexes()
protected void
doAddMessagesToGroup(ObjectSE groupId, Message<?>... messages)
protected void
doCompleteGroup(ObjectSE groupId)
protected void
doRemoveMessageGroup(ObjectSE groupId)
protected void
doRemoveMessagesFromGroup(ObjectSE key, CollectionSE<Message<?>> messages)
protected void
doSetGroupCondition(ObjectSE groupId, StringSE condition)
protected void
doSetLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber)
protected ApplicationContext
getApplicationContext()
protected MappingMongoConverter
getMappingMongoConverter()
Message<?>
getMessage(UUIDSE id)
protected MessageBuilderFactory
getMessageBuilderFactory()
MessageMetadata
getMessageMetadata(UUIDSE id)
CollectionSE<Message<?>>
getMessagesForGroup(ObjectSE groupId)
指定されたグループ ID のメッセージを取得します。
protected MongoTemplate
getMongoTemplate()
protected long
getNextId()
MessageDocument sequence を含むドキュメントに対して MongoDB INC 操作を実行し、新しい MessageDocument の新しい増分値を返します。
Message<?>
getOneMessageFromGroup(ObjectSE groupId)
MessageGroup から 1 つの Message を返します。
protected static Query
groupIdQuery(ObjectSE groupId)
IteratorSE<MessageGroup>
iterator()
int
messageGroupSize(ObjectSE groupId)
この MessageGroup のサイズを返します。
void
setApplicationContext(ApplicationContext applicationContext)
void
setCreateIndexes(boolean createIndexes)
インデックスを自動作成するかどうかのオプションを定義します。
クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたメソッド
addMessagesToGroup, addMessageToGroup, completeGroup, copy, doPollMessageFromGroup, doRemoveMessageFromGroupById, executeLocked, executeLocked, expireMessageGroups, getGroupMetadata, 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
インターフェース org.springframework.integration.store.BasicMessageGroupStore から継承されたメソッド
getMessageGroup
インターフェース java.lang.IterableSE から継承されたメソッド
forEachSE, spliterator
インターフェース org.springframework.integration.store.MessageGroupStore から継承されたメソッド
getMessageFromGroup, streamMessagesForGroup

フィールドの詳細
- SEQUENCE_NAME
  public static final StringSE SEQUENCE_NAME
  関連事項:
  定数フィールド値
- logger
  protected final Log logger
- collectionName
  protected final StringSE collectionName
- mongoDbFactory
  protected final MongoDatabaseFactory mongoDbFactory
コンストラクターの詳細
- AbstractConfigurableMongoDbMessageStore
  public AbstractConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate, StringSE collectionName)
- AbstractConfigurableMongoDbMessageStore
  public AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, StringSE collectionName)
- AbstractConfigurableMongoDbMessageStore
  public AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter, StringSE collectionName)
メソッドの詳細
- setCreateIndexes
  public void setCreateIndexes(boolean createIndexes)
  インデックスを自動作成するかどうかのオプションを定義します。
  パラメーター:
  createIndexes - ブール値。
  導入:
  6.0.8.
- setApplicationContext
  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
  次で指定:
  インターフェース ApplicationContextAware の setApplicationContext
  例外:
  BeansException
- getMongoTemplate
  protected MongoTemplate getMongoTemplate()
- getMappingMongoConverter
  protected MappingMongoConverter getMappingMongoConverter()
- getApplicationContext
  protected ApplicationContext getApplicationContext()
- getMessageBuilderFactory
  protected MessageBuilderFactory getMessageBuilderFactory()
- afterPropertiesSet
  public void afterPropertiesSet()
  次で指定:
  インターフェース InitializingBean の afterPropertiesSet
- createIndexes
  protected void createIndexes()
- getMessage
  public Message<?> getMessage(UUIDSE id)
- getMessageMetadata
  public MessageMetadata getMessageMetadata(UUIDSE id)
- doRemoveMessageGroup
  protected void doRemoveMessageGroup(ObjectSE groupId)
  次で指定:
  クラス AbstractMessageGroupStore の doRemoveMessageGroup
- messageGroupSize
  public int messageGroupSize(ObjectSE groupId)
  インターフェースからコピーされた説明: BasicMessageGroupStore
  この MessageGroup のサイズを返します。
  次で指定:
  インターフェース BasicMessageGroupStore の messageGroupSize
  パラメーター:
  groupId - グループ識別子。
  戻り値:
  サイズ。
- getNextId
  protected long getNextId()
  MessageDocument sequence を含むドキュメントに対して MongoDB INC 操作を実行し、新しい MessageDocument の新しい増分値を返します。SEQUENCE_NAME ドキュメントはオンデマンドで作成されます。
  戻り値:
  次のシーケンス値。
- addMessageDocument
  protected void addMessageDocument(MessageDocument document)
- groupIdQuery
  protected static Query groupIdQuery(ObjectSE groupId)
- doRemoveMessagesFromGroup
  protected void doRemoveMessagesFromGroup(ObjectSE key, CollectionSE<Message<?>> messages)
  次で指定:
  クラス AbstractMessageGroupStore の doRemoveMessagesFromGroup
- doSetGroupCondition
  protected void doSetGroupCondition(ObjectSE groupId, StringSE condition)
  次で指定:
  クラス AbstractMessageGroupStore の doSetGroupCondition
- doSetLastReleasedSequenceNumberForGroup
  protected void doSetLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber)
  次で指定:
  クラス AbstractMessageGroupStore の doSetLastReleasedSequenceNumberForGroup
- iterator
  public IteratorSE<MessageGroup> iterator()
  次で指定:
  インターフェース IterableSE<MessageGroup> の iterator
  次で指定:
  インターフェース MessageGroupStore の iterator
  戻り値:
  現在累積されている MessageGroup の反復子。
- doCompleteGroup
  protected void doCompleteGroup(ObjectSE groupId)
  次で指定:
  クラス AbstractMessageGroupStore の doCompleteGroup
- getOneMessageFromGroup
  public Message<?> getOneMessageFromGroup(ObjectSE groupId)
  インターフェースからコピーされた説明: MessageGroupStore
  MessageGroup から 1 つの Message を返します。
  次で指定:
  インターフェース MessageGroupStore の getOneMessageFromGroup
  パラメーター:
  groupId - グループ識別子。
  戻り値:
  Message
- doAddMessagesToGroup
  protected void doAddMessagesToGroup(ObjectSE groupId, Message<?>... messages)
  次で指定:
  クラス AbstractMessageGroupStore の doAddMessagesToGroup
- getMessagesForGroup
  public CollectionSE<Message<?>> getMessagesForGroup(ObjectSE groupId)
  インターフェースからコピーされた説明: MessageGroupStore
  指定されたグループ ID のメッセージを取得します。
  次で指定:
  インターフェース MessageGroupStore の getMessagesForGroup
  パラメーター:
  groupId - メッセージを取得するグループ ID。
  戻り値:
  グループのメッセージ。

クラス AbstractConfigurableMongoDbMessageStore

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

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

フィールドのサマリー

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

コンストラクターの概要

メソッドのサマリー

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

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

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

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

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

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

フィールドの詳細

SEQUENCE_NAME

logger

collectionName

mongoDbFactory

コンストラクターの詳細

AbstractConfigurableMongoDbMessageStore

AbstractConfigurableMongoDbMessageStore

AbstractConfigurableMongoDbMessageStore

メソッドの詳細

setCreateIndexes

setApplicationContext

getMongoTemplate

getMappingMongoConverter

getApplicationContext

getMessageBuilderFactory

afterPropertiesSet

createIndexes

getMessage

getMessageMetadata

doRemoveMessageGroup

messageGroupSize

getNextId

addMessageDocument

groupIdQuery

doRemoveMessagesFromGroup

doSetGroupCondition

doSetLastReleasedSequenceNumberForGroup

iterator

doCompleteGroup

getOneMessageFromGroup

doAddMessagesToGroup

getMessagesForGroup