public final class MessageChannels
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static DirectChannelSpec |
direct() |
static DirectChannelSpec |
direct(java.lang.String id) |
static ExecutorChannelSpec |
executor(java.util.concurrent.Executor executor) |
static ExecutorChannelSpec |
executor(java.lang.String id,
java.util.concurrent.Executor executor) |
static PriorityChannelSpec |
priority() |
static QueueChannelSpec.MessageStoreSpec |
priority(org.springframework.integration.store.PriorityCapableChannelMessageStore messageGroupStore,
java.lang.Object groupId) |
static PriorityChannelSpec |
priority(java.lang.String id) |
static QueueChannelSpec.MessageStoreSpec |
priority(java.lang.String id,
org.springframework.integration.store.PriorityCapableChannelMessageStore messageGroupStore,
java.lang.Object groupId) |
static <S extends PublishSubscribeChannelSpec<S>> |
publishSubscribe() |
static <S extends PublishSubscribeChannelSpec<S>> |
publishSubscribe(java.util.concurrent.Executor executor) |
static <S extends PublishSubscribeChannelSpec<S>> |
publishSubscribe(java.lang.String id) |
static <S extends PublishSubscribeChannelSpec<S>> |
publishSubscribe(java.lang.String id,
java.util.concurrent.Executor executor) |
static QueueChannelSpec |
queue() |
static QueueChannelSpec.MessageStoreSpec |
queue(org.springframework.integration.store.ChannelMessageStore messageGroupStore,
java.lang.Object groupId) |
static QueueChannelSpec |
queue(java.lang.Integer capacity) |
static QueueChannelSpec |
queue(java.util.Queue<org.springframework.messaging.Message<?>> queue) |
static QueueChannelSpec |
queue(java.lang.String id) |
static QueueChannelSpec.MessageStoreSpec |
queue(java.lang.String id,
org.springframework.integration.store.ChannelMessageStore messageGroupStore,
java.lang.Object groupId) |
static QueueChannelSpec |
queue(java.lang.String id,
java.lang.Integer capacity) |
static QueueChannelSpec |
queue(java.lang.String id,
java.util.Queue<org.springframework.messaging.Message<?>> queue) |
static RendezvousChannelSpec |
rendezvous() |
static RendezvousChannelSpec |
rendezvous(java.lang.String id) |
public static DirectChannelSpec direct()
public static DirectChannelSpec direct(java.lang.String id)
public static QueueChannelSpec queue()
public static QueueChannelSpec queue(java.lang.String id)
public static QueueChannelSpec queue(java.util.Queue<org.springframework.messaging.Message<?>> queue)
public static QueueChannelSpec queue(java.lang.String id, java.util.Queue<org.springframework.messaging.Message<?>> queue)
public static QueueChannelSpec queue(java.lang.Integer capacity)
public static QueueChannelSpec queue(java.lang.String id, java.lang.Integer capacity)
public static QueueChannelSpec.MessageStoreSpec queue(org.springframework.integration.store.ChannelMessageStore messageGroupStore, java.lang.Object groupId)
public static QueueChannelSpec.MessageStoreSpec queue(java.lang.String id, org.springframework.integration.store.ChannelMessageStore messageGroupStore, java.lang.Object groupId)
public static ExecutorChannelSpec executor(java.util.concurrent.Executor executor)
public static ExecutorChannelSpec executor(java.lang.String id, java.util.concurrent.Executor executor)
public static RendezvousChannelSpec rendezvous()
public static RendezvousChannelSpec rendezvous(java.lang.String id)
public static PriorityChannelSpec priority()
public static PriorityChannelSpec priority(java.lang.String id)
public static QueueChannelSpec.MessageStoreSpec priority(org.springframework.integration.store.PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId)
public static QueueChannelSpec.MessageStoreSpec priority(java.lang.String id, org.springframework.integration.store.PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId)
public static <S extends PublishSubscribeChannelSpec<S>> PublishSubscribeChannelSpec<S> publishSubscribe()
public static <S extends PublishSubscribeChannelSpec<S>> PublishSubscribeChannelSpec<S> publishSubscribe(java.lang.String id)
public static <S extends PublishSubscribeChannelSpec<S>> PublishSubscribeChannelSpec<S> publishSubscribe(java.util.concurrent.Executor executor)
public static <S extends PublishSubscribeChannelSpec<S>> PublishSubscribeChannelSpec<S> publishSubscribe(java.lang.String id, java.util.concurrent.Executor executor)