クラス MongoDbMessageStore

メソッドの詳細

• setBeanClassLoader

  public void setBeanClassLoader(ClassLoaderSE classLoader)

  次で指定:

  インターフェース BeanClassLoaderAware の setBeanClassLoader 

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• addAllowedPatterns

  public void addAllowedPatterns(StringSE @Nullable ... patterns)

  逆直列化できるパッケージ / クラスのパターンを追加します。クラスは完全修飾することも、クラス名の最初または最後にワイルドカード "*" を使用することもできます。例: com.foo.*、*.MyClass。

  パラメーター:

  patterns - パターン。

  導入:

  5.4

• setCustomConverters

  public void setCustomConverters(ObjectSE... customConverters)

  MappingMongoConverter で使用するコンバーターのセットを構成します。org.springframework.core.convert.converter.Converter、org.springframework.core.convert.converter.ConverterFactory、org.springframework.core.convert.converter.GenericConverter または org.springframework.data.convert.ConverterBuilder.ConverterAware のインスタンスである必要があります。

  パラメーター:

  customConverters - 使用するコンバーター。

  導入:

  5.1.6

• afterPropertiesSet

  public void afterPropertiesSet()

  次で指定:

  インターフェース InitializingBean の afterPropertiesSet 

• addMessage

  public <T> Message<T> addMessage(Message<T> message)

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

  提供されたメッセージを MessageStore に格納します。ストアは内部的にメッセージを変更する必要がある可能性があり、その場合、戻り値は入力値と異なる場合があります。戻り値の ID は、MessageStore.getMessage(UUID) と MessageStore.removeMessage(UUID) が正しく動作するためのインデックスとして使用されます。メッセージは不変であるため、同じメッセージを複数回格納しても何も起こりません。

  次で指定:

  インターフェース MessageStore の addMessage 

  型パラメーター:

  T - ペイロード型。

  パラメーター:

  message - メッセージ。

  戻り値:

  保存されたメッセージ。

• getMessage

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

  次で指定:

  インターフェース MessageStore の getMessage 

  パラメーター:

  id - メッセージ識別子。

  戻り値:

  指定された ID のメッセージ。MessageStore にその ID のメッセージが存在しない場合は null。

• getMessageMetadata

  public @Nullable MessageMetadata getMessageMetadata(UUIDSE id)

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

  提供された id によって Message の MessageMetadata を返します。

  次で指定:

  インターフェース MessageStore の getMessageMetadata 

  パラメーター:

  id - メッセージ識別子。

  戻り値:

  指定された ID の MessageMetadata、またはその ID のメッセージが MessageStore に存在しないか、メッセージにメタデータがない場合（以前のバージョンのレガシーメッセージ）は null。

• getMessageCount

  @ManagedAttribute public long getMessageCount()

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

  ストア内のメッセージ数を示すオプションの属性。実装は例外をスローすることで応答を拒否する場合があります。

  次で指定:

  インターフェース MessageStore の getMessageCount 

  戻り値:

  メッセージの数。

• removeMessage

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

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

  指定された ID を持つメッセージが MessageStore から削除されます (存在する場合)。その ID を持つメッセージがストアに存在しない場合は、null が返されます。このメソッドが MessageGroupStore に実装されている場合、このメッセージを保持するグループがない場合にのみ、メッセージはストアから削除されます。

  次で指定:

  インターフェース MessageStore の removeMessage 

  パラメーター:

  id - メッセージ識別子。

  戻り値:

  メッセージ (ある場合)。

• getMessageGroup

  public MessageGroup getMessageGroup(ObjectSE groupId)

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

  このグループ ID で BasicMessageGroupStore.addMessageToGroup(Object, Message) を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。

  次で指定:

  インターフェース BasicMessageGroupStore の getMessageGroup 

  パラメーター:

  groupId - グループ識別子。

  戻り値:

  メッセージのグループ。このキーにメッセージが存在しない場合は空です。

• doAddMessagesToGroup

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

  次で指定:

  クラス AbstractMessageGroupStore の doAddMessagesToGroup 

• doRemoveMessagesFromGroup

  protected void doRemoveMessagesFromGroup(ObjectSE groupId, CollectionSE<Message<?>> messages)

  次で指定:

  クラス AbstractMessageGroupStore の doRemoveMessagesFromGroup 

• getMessageFromGroup

  public @Nullable Message<?> getMessageFromGroup(ObjectSE groupId, UUIDSE messageId)

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

  ID を使用してグループから Message を取得します。メッセージがリクエストされたグループに属していない場合は、null を返します。

  次で指定:

  インターフェース MessageGroupStore の getMessageFromGroup 

  パラメーター:

  groupId - メッセージを含むグループの groupId。

  messageId - メッセージ ID。

  戻り値:

  リクエストされたグループに属している場合は、ID によるメッセージ。

• doRemoveMessageFromGroupById

  protected boolean doRemoveMessageFromGroupById(ObjectSE groupId, UUIDSE messageId)

  オーバーライド:

  クラス AbstractMessageGroupStore の doRemoveMessageFromGroupById 

• doRemoveMessageGroup

  protected void doRemoveMessageGroup(ObjectSE groupId)

  次で指定:

  クラス AbstractMessageGroupStore の doRemoveMessageGroup 

• iterator

  public IteratorSE<MessageGroup> iterator()

  次で指定:

  インターフェース IterableSE<MessageGroup> の iterator 

  次で指定:

  インターフェース MessageGroupStore の iterator 

  戻り値:

  現在累積されている MessageGroup の反復子。

• doPollMessageFromGroup

  protected @Nullable Message<?> doPollMessageFromGroup(ObjectSE groupId)

  次で指定:

  クラス AbstractMessageGroupStore の doPollMessageFromGroup 

• messageGroupSize

  public int messageGroupSize(ObjectSE groupId)

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

  この MessageGroup のサイズを返します。

  次で指定:

  インターフェース BasicMessageGroupStore の messageGroupSize 

  パラメーター:

  groupId - グループ識別子。

  戻り値:

  サイズ。

• doSetGroupCondition

  protected void doSetGroupCondition(ObjectSE groupId, StringSE condition)

  次で指定:

  クラス AbstractMessageGroupStore の doSetGroupCondition 

• doSetLastReleasedSequenceNumberForGroup

  protected void doSetLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber)

  次で指定:

  クラス AbstractMessageGroupStore の doSetLastReleasedSequenceNumberForGroup 

• doCompleteGroup

  protected void doCompleteGroup(ObjectSE groupId)

  次で指定:

  クラス AbstractMessageGroupStore の doCompleteGroup 

• getOneMessageFromGroup

  public @Nullable Message<?> getOneMessageFromGroup(ObjectSE groupId)

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

  MessageGroup から 1 つの Message を返します。

  次で指定:

  インターフェース MessageGroupStore の getOneMessageFromGroup 

  パラメーター:

  groupId - グループ識別子。

  戻り値:

  Message

• getMessagesForGroup

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

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

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

  次で指定:

  インターフェース MessageGroupStore の getMessagesForGroup 

  パラメーター:

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

  戻り値:

  グループのメッセージ。

• streamMessagesForGroup

  public StreamSE<Message<?>> streamMessagesForGroup(ObjectSE groupId)

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

  指定されたグループに保存されているメッセージのストリームを返します。永続的な実装は、完全に処理されたら閉じる必要があるストリームを返します（たとえば、try-with-resources 句を使用）。デフォルトでは、MessageGroupStore.getMessagesForGroup(Object) の結果をストリーミングします。

  次で指定:

  インターフェース MessageGroupStore の streamMessagesForGroup 

  パラメーター:

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

  戻り値:

  このグループのメッセージの StreamSE。

• getMessageCountForAllMessageGroups

  @ManagedAttribute public int getMessageCountForAllMessageGroups()

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

  すべてのグループにわたるストア内のメッセージの数を示すオプションの属性。実装は、例外をスローすることによって応答を拒否する場合があります。

  次で指定:

  インターフェース MessageGroupStore の getMessageCountForAllMessageGroups 

  オーバーライド:

  クラス AbstractMessageGroupStore の getMessageCountForAllMessageGroups 

  戻り値:

  メッセージの数

• getMessageGroupCount

  @ManagedAttribute public int getMessageGroupCount()

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

  メッセージグループの数を示すオプションの属性。実装は、例外をスローすることによって応答を拒否する場合があります。

  次で指定:

  インターフェース MessageGroupStore の getMessageGroupCount 

  オーバーライド:

  クラス AbstractMessageGroupStore の getMessageGroupCount 

  戻り値:

  メッセージグループの数