Package org.springframework.integration.dsl

Class Channels

java.lang.Object

org.springframework.integration.dsl.Channels

public final class Channels
extends Object

Since:

5.0

Author:

Artem Bilan, Gary Russell

Method Summary

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

direct

public DirectChannelSpec direct(String id)

queue

public QueueChannelSpec queue()

queue

public QueueChannelSpec queue(String id)

queue

public QueueChannelSpec queue(Integer capacity)

queue

public QueueChannelSpec queue(String id,
 Integer capacity)

queue

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

queue

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

queue

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

queue

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

priority

public PriorityChannelSpec priority()

priority

public PriorityChannelSpec priority(String id)

priority

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

rendezvous

public RendezvousChannelSpec rendezvous()

priority

public PriorityChannelSpec priority(PriorityCapableChannelMessageStore messageGroupStore,
 Object groupId)

rendezvous

public RendezvousChannelSpec rendezvous(String id)

publishSubscribe

public PublishSubscribeChannelSpec<?> publishSubscribe()

publishSubscribe

public PublishSubscribeChannelSpec<?> publishSubscribe(boolean requireSubscribers)

publishSubscribe

public PublishSubscribeChannelSpec<?> publishSubscribe(Executor executor)

publishSubscribe

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

publishSubscribe

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

publishSubscribe

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

publishSubscribe

public PublishSubscribeChannelSpec<?> publishSubscribe(String id)

publishSubscribe

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

executor

public ExecutorChannelSpec executor(Executor executor)

executor

public ExecutorChannelSpec executor(String id,
 Executor executor)

flux

public FluxMessageChannelSpec flux()

flux

public FluxMessageChannelSpec flux(String id)

partitioned

public PartitionedChannelSpec partitioned(int partitionCount)

Create a PartitionedChannelSpec.

Parameters:

partitionCount - the number of partitions in the channel.

Returns:

the PartitionedChannelSpec.

Since:

6.1

partitioned

public 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