クラス MessageChannels

メソッドの詳細

• direct

  public static DirectChannelSpec direct()

• direct

  public static DirectChannelSpec direct(StringSE id)

• queue

  public static QueueChannelSpec queue()

• queue

  public static QueueChannelSpec queue(StringSE id)

• queue

  public static QueueChannelSpec queue(QueueSE<Message<?>> queue)

• queue

  public static QueueChannelSpec queue(StringSE id, QueueSE<Message<?>> queue)

• queue

  public static QueueChannelSpec queue(IntegerSE capacity)

• queue

  public static QueueChannelSpec queue(StringSE id, IntegerSE capacity)

• queue

  public static QueueChannelSpec.MessageStoreSpec queue(ChannelMessageStore messageGroupStore, ObjectSE groupId)

• queue

  public static QueueChannelSpec.MessageStoreSpec queue(StringSE id, ChannelMessageStore messageGroupStore, ObjectSE groupId)

• executor

  public static ExecutorChannelSpec executor(ExecutorSE executor)

• executor

  public static ExecutorChannelSpec executor(StringSE id, ExecutorSE executor)

• rendezvous

  public static RendezvousChannelSpec rendezvous()

• rendezvous

  public static RendezvousChannelSpec rendezvous(StringSE id)

• priority

  public static PriorityChannelSpec priority()

• priority

  public static PriorityChannelSpec priority(StringSE id)

• priority

  public static PriorityChannelSpec priority(PriorityCapableChannelMessageStore messageGroupStore, ObjectSE groupId)

• priority

  public static PriorityChannelSpec priority(StringSE id, PriorityCapableChannelMessageStore messageGroupStore, ObjectSE groupId)

• publishSubscribe

  public static PublishSubscribeChannelSpec<?> publishSubscribe()

• publishSubscribe

  public static PublishSubscribeChannelSpec<?> publishSubscribe(boolean requireSubscribers)

• publishSubscribe

  public static PublishSubscribeChannelSpec<?> publishSubscribe(StringSE id)

• publishSubscribe

  public static PublishSubscribeChannelSpec<?> publishSubscribe(StringSE id, boolean requireSubscribers)

• publishSubscribe

  public static PublishSubscribeChannelSpec<?> publishSubscribe(ExecutorSE executor)

• publishSubscribe

  public static PublishSubscribeChannelSpec<?> publishSubscribe(ExecutorSE executor, boolean requireSubscribers)

• publishSubscribe

  public static PublishSubscribeChannelSpec<?> publishSubscribe(StringSE id, ExecutorSE executor)

• publishSubscribe

  public static PublishSubscribeChannelSpec<?> publishSubscribe(StringSE id, ExecutorSE executor, boolean requireSubscribers)

• flux

  public static FluxMessageChannelSpec flux()

• flux

  public static FluxMessageChannelSpec flux(StringSE id)

• partitioned

  public static PartitionedChannelSpec partitioned(int partitionCount)

  PartitionedChannelSpec を作成します。

  パラメーター:

  partitionCount - チャネル内のパーティションの数。

  戻り値:

  PartitionedChannelSpec

  導入:

  6.1

• partitioned

  public static PartitionedChannelSpec partitioned(StringSE id, int partitionCount)

  PartitionedChannelSpec を作成します。

  パラメーター:

  id - チャネルの Bean 名。

  partitionCount - チャネル内のパーティションの数。

  戻り値:

  PartitionedChannelSpec

  導入:

  6.1