Package org.springframework.integration.dsl

Class MessageChannels

java.lang.Object

org.springframework.integration.dsl.MessageChannels

public final class MessageChannels
extends Object

Since:

5.0

Author:

Artem Bilan, Gary Russell

Method Summary

Modifier and Type	Method	Description
static DirectChannelSpec	direct()
static DirectChannelSpec	direct(String id)
static ExecutorChannelSpec	executor(String id, Executor executor)
static ExecutorChannelSpec	executor(Executor executor)
static FluxMessageChannelSpec	flux()
static FluxMessageChannelSpec	flux(String id)
static PartitionedChannelSpec	partitioned(int partitionCount)	Create a PartitionedChannelSpec.
static PartitionedChannelSpec	partitioned(String id, int partitionCount)	Create a PartitionedChannelSpec.
static PriorityChannelSpec	priority()
static PriorityChannelSpec	priority(String id)
static PriorityChannelSpec	priority(String id, PriorityCapableChannelMessageStore messageGroupStore, Object groupId)
static PriorityChannelSpec	priority(PriorityCapableChannelMessageStore messageGroupStore, Object groupId)
static PublishSubscribeChannelSpec<?>	publishSubscribe()
static PublishSubscribeChannelSpec<?>	publishSubscribe(boolean requireSubscribers)
static PublishSubscribeChannelSpec<?>	publishSubscribe(String id)
static PublishSubscribeChannelSpec<?>	publishSubscribe(String id, boolean requireSubscribers)
static PublishSubscribeChannelSpec<?>	publishSubscribe(String id, Executor executor)
static PublishSubscribeChannelSpec<?>	publishSubscribe(String id, Executor executor, boolean requireSubscribers)
static PublishSubscribeChannelSpec<?>	publishSubscribe(Executor executor)
static PublishSubscribeChannelSpec<?>	publishSubscribe(Executor executor, boolean requireSubscribers)
static QueueChannelSpec	queue()
static QueueChannelSpec	queue(Integer capacity)
static QueueChannelSpec	queue(String id)
static QueueChannelSpec	queue(String id, Integer capacity)
static QueueChannelSpec	queue(String id, Queue<Message<?>> queue)
static QueueChannelSpec.MessageStoreSpec	queue(String id, ChannelMessageStore messageGroupStore, Object groupId)
static QueueChannelSpec	queue(Queue<Message<?>> queue)
static QueueChannelSpec.MessageStoreSpec	queue(ChannelMessageStore messageGroupStore, Object groupId)
static RendezvousChannelSpec	rendezvous()
static RendezvousChannelSpec	rendezvous(String id)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

direct

public static DirectChannelSpec direct()

direct

public static DirectChannelSpec direct(String id)

queue

public static QueueChannelSpec queue()

queue

public static QueueChannelSpec queue(String id)

queue

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

queue

public static QueueChannelSpec queue(String id,
 Queue<Message<?>> queue)

queue

public static QueueChannelSpec queue(Integer capacity)

queue

public static QueueChannelSpec queue(String id,
 Integer capacity)

queue

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

queue

public static QueueChannelSpec.MessageStoreSpec queue(String id,
 ChannelMessageStore messageGroupStore,
 Object groupId)

executor

public static ExecutorChannelSpec executor(Executor executor)

executor

public static ExecutorChannelSpec executor(String id,
 Executor executor)

rendezvous

public static RendezvousChannelSpec rendezvous()

rendezvous

public static RendezvousChannelSpec rendezvous(String id)

priority

public static PriorityChannelSpec priority()

priority

public static PriorityChannelSpec priority(String id)

priority

public static PriorityChannelSpec priority(PriorityCapableChannelMessageStore messageGroupStore,
 Object groupId)

priority

public static PriorityChannelSpec priority(String id,
 PriorityCapableChannelMessageStore messageGroupStore,
 Object groupId)

publishSubscribe

public static PublishSubscribeChannelSpec<?> publishSubscribe()

publishSubscribe

public static PublishSubscribeChannelSpec<?> publishSubscribe(boolean requireSubscribers)

publishSubscribe

public static PublishSubscribeChannelSpec<?> publishSubscribe(String id)

publishSubscribe

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

publishSubscribe

public static PublishSubscribeChannelSpec<?> publishSubscribe(Executor executor)

publishSubscribe

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

publishSubscribe

public static PublishSubscribeChannelSpec<?> publishSubscribe(String id,
 Executor executor)

publishSubscribe

public static PublishSubscribeChannelSpec<?> publishSubscribe(String id,
 Executor executor,
 boolean requireSubscribers)

flux

public static FluxMessageChannelSpec flux()

flux

public static FluxMessageChannelSpec flux(String id)

partitioned

public static PartitionedChannelSpec partitioned(int partitionCount)

Create a PartitionedChannelSpec.

Parameters:

partitionCount - the number of partitions in the channel.

Returns:

the PartitionedChannelSpec.

Since:

6.1

partitioned

public static PartitionedChannelSpec partitioned(String id,
 int partitionCount)

Create a PartitionedChannelSpec.

Parameters:

id - the bean name for the channel.

partitionCount - the number of partitions in the channel.

Returns:

the PartitionedChannelSpec.

Since:

6.1