クラス AbstractConfigurableMongoDbMessageStore

方法の詳細

• 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 @Nullable MappingMongoConverter getMappingMongoConverter()

• getApplicationContext

  protected ApplicationContext getApplicationContext()

• getMessageBuilderFactory

  protected MessageBuilderFactory getMessageBuilderFactory()

• afterPropertiesSet

  public void afterPropertiesSet()

  次で指定:

  インターフェース InitializingBean 内の afterPropertiesSet 

• createIndexes

  protected void createIndexes()

• getMessage

  public @Nullable Message<?> getMessage(UUIDSE id)

• getMessageMetadata

  public @Nullable 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 

• doAddMessagesToGroup

  protected void doAddMessagesToGroup(ObjectSE groupId, Message<?>... messages)

  次で指定:

  クラス AbstractMessageGroupStore の doAddMessagesToGroup 

• getMessagesForGroup

  public CollectionSE<Message<?>> getMessagesForGroup(ObjectSE groupId)

  インターフェースからコピーされた説明: MessageGroupStore

  指定されたグループ ID のメッセージを取得します。

  次で指定:

  インターフェース MessageGroupStore 内の getMessagesForGroup 

  パラメーター:

  groupId - メッセージを取得するグループ ID。

  戻り値:

  グループのメッセージ。