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

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(String id)

publishSubscribe

public static PublishSubscribeChannelSpec<?> publishSubscribe(Executor executor)

publishSubscribe

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

flux

public static FluxMessageChannelSpec flux()

flux

public static FluxMessageChannelSpec flux(String id)