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 and Description
DirectChannelSpec	direct()
DirectChannelSpec	direct(String id)
ExecutorChannelSpec	executor(Executor executor)
ExecutorChannelSpec	executor(String id, Executor executor)
FluxMessageChannelSpec	flux()
FluxMessageChannelSpec	flux(String id)
PriorityChannelSpec	priority()
PriorityChannelSpec	priority(PriorityCapableChannelMessageStore messageGroupStore, Object groupId)
PriorityChannelSpec	priority(String id)
PriorityChannelSpec	priority(String id, PriorityCapableChannelMessageStore messageGroupStore, Object groupId)
PublishSubscribeChannelSpec<?>	publishSubscribe()
PublishSubscribeChannelSpec<?>	publishSubscribe(Executor executor)
PublishSubscribeChannelSpec<?>	publishSubscribe(String id)
PublishSubscribeChannelSpec<?>	publishSubscribe(String id, Executor executor)
QueueChannelSpec	queue()
QueueChannelSpec.MessageStoreSpec	queue(ChannelMessageStore messageGroupStore, Object groupId)
QueueChannelSpec	queue(Integer capacity)
QueueChannelSpec	queue(Queue<Message<?>> queue)
QueueChannelSpec	queue(String id)
QueueChannelSpec.MessageStoreSpec	queue(String id, ChannelMessageStore messageGroupStore, Object groupId)
QueueChannelSpec	queue(String id, Integer capacity)
QueueChannelSpec	queue(String id, Queue<Message<?>> queue)
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 Detail

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(Executor executor)

publishSubscribe

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

publishSubscribe

public PublishSubscribeChannelSpec<?> publishSubscribe(String id)

executor

public ExecutorChannelSpec executor(Executor executor)

executor

public ExecutorChannelSpec executor(String id,
                                    Executor executor)

flux

public FluxMessageChannelSpec flux()

flux

public FluxMessageChannelSpec flux(String id)