クラス MessageGroupQueue

方法の詳細

• setPriority

  public void setPriority(boolean priority)

  true の場合、メッセージストアが優先度をサポートしていることを確認します。false の場合メッセージストアが優先度を使用して受信時にメッセージの順序を決定する場合に警告します。

  パラメーター:

  priority - 優先度が使用されると予想される場合は true。

• iterator

  public IteratorSE<Message<?>> iterator()

  次で指定:

  インターフェース CollectionSE<Message<?>> 内の iterator 

  次で指定:

  インターフェース IterableSE<Message<?>> 内の iterator 

  次で指定:

  クラス AbstractCollectionSE<Message<?>> の iterator 

• getMessageGroupStore

  protected BasicMessageGroupStore getMessageGroupStore()

  ストアを取得します。

  戻り値:

  ストア。

  導入:

  5.0.11

• getStoreLock

  protected LockSE getStoreLock()

  ストアロックを取得します。

  戻り値:

  ロック。

  導入:

  5.0.11

• getMessageStoreNotFull

  protected ConditionSE getMessageStoreNotFull()

  完全ではない状態になります。

  戻り値:

  状態。

  導入:

  5.0.11

• getMessageStoreNotEmpty

  protected ConditionSE getMessageStoreNotEmpty()

  空ではない状態を取得します。

  戻り値:

  状態。

  導入:

  5.0.11

• size

  public int size()

  次で指定:

  インターフェース CollectionSE<Message<?>> 内の size 

  次で指定:

  クラス AbstractCollectionSE<Message<?>> の size 

• peek

  public @Nullable Message<?> peek()

  次で指定:

  インターフェース QueueSE<Message<?>> 内の peek 

• poll

  public @Nullable Message<?> poll(long timeout, TimeUnitSE unit) throws InterruptedExceptionSE

  次で指定:

  インターフェース BlockingQueueSE<Message<?>> 内の pollSE 

  例外:

  InterruptedExceptionSE

• poll

  public @Nullable Message<?> poll()

  次で指定:

  インターフェース QueueSE<Message<?>> 内の poll 

• drainTo

  public int drainTo(CollectionSE<? super Message<?>> c)

  次で指定:

  インターフェース BlockingQueueSE<Message<?>> 内の drainToSE 

• drainTo

  public int drainTo(CollectionSE<? super Message<?>> collection, int maxElements)

  次で指定:

  インターフェース BlockingQueueSE<Message<?>> 内の drainToSE 

• offer

  public boolean offer(Message<?> message)

  次で指定:

  インターフェース BlockingQueueSE<Message<?>> 内の offerSE 

  次で指定:

  インターフェース QueueSE<Message<?>> 内の offerSE 

• offer

  public boolean offer(Message<?> message, long timeout, TimeUnitSE unit) throws InterruptedExceptionSE

  次で指定:

  インターフェース BlockingQueueSE<Message<?>> 内の offerSE 

  例外:

  InterruptedExceptionSE

• put

  public void put(Message<?> message) throws InterruptedExceptionSE

  次で指定:

  インターフェース BlockingQueueSE<Message<?>> 内の putSE 

  例外:

  InterruptedExceptionSE

• remainingCapacity

  public int remainingCapacity()

  次で指定:

  インターフェース BlockingQueueSE<Message<?>> 内の remainingCapacity 

• take

  public Message<?> take() throws InterruptedExceptionSE

  次で指定:

  インターフェース BlockingQueueSE<Message<?>> 内の take 

  例外:

  InterruptedExceptionSE

• getMessages

  protected CollectionSE<Message<?>> getMessages()

• stream

  public StreamSE<Message<?>> stream()

  次で指定:

  インターフェース CollectionSE<Message<?>> 内の stream 

• doPoll

  protected @Nullable Message<?> doPoll()

  'storeLock' は呼び出し元によって保持されているものと想定されます。そうでない場合は、IllegalMonitorStateException がスローされる可能性があります。

  戻り値:

  メッセージ

• doOffer

  protected boolean doOffer(Message<?> message)

  'storeLock' は呼び出し元によって保持されているものと想定されます。そうでない場合は、IllegalMonitorStateException がスローされる可能性があります。

  パラメーター:

  message - 提供するメッセージ。

  戻り値:

  提供された場合は true。