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 FluxMessageChannelSpec |
flux() |
static FluxMessageChannelSpec |
flux(java.lang.String id) |
static PriorityChannelSpec |
priority() |
static PriorityChannelSpec |
priority(PriorityCapableChannelMessageStore messageGroupStore,
java.lang.Object groupId) |
static PriorityChannelSpec |
priority(java.lang.String id) |
static PriorityChannelSpec |
priority(java.lang.String id,
PriorityCapableChannelMessageStore messageGroupStore,
java.lang.Object groupId) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe() |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(boolean requireSubscribers) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(java.util.concurrent.Executor executor) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(java.util.concurrent.Executor executor,
boolean requireSubscribers) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(java.lang.String id) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(java.lang.String id,
boolean requireSubscribers) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(java.lang.String id,
java.util.concurrent.Executor executor) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(java.lang.String id,
java.util.concurrent.Executor executor,
boolean requireSubscribers) |
static QueueChannelSpec |
queue() |
static QueueChannelSpec.MessageStoreSpec |
queue(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,
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(ChannelMessageStore messageGroupStore, java.lang.Object groupId)
public static QueueChannelSpec.MessageStoreSpec queue(java.lang.String id, 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 PriorityChannelSpec priority(PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId)
public static PriorityChannelSpec priority(java.lang.String id, PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId)
public static PublishSubscribeChannelSpec<?> publishSubscribe()
public static PublishSubscribeChannelSpec<?> publishSubscribe(boolean requireSubscribers)
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.lang.String id)
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.lang.String id, boolean requireSubscribers)
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.util.concurrent.Executor executor)
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.util.concurrent.Executor executor, boolean requireSubscribers)
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.lang.String id, java.util.concurrent.Executor executor)
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.lang.String id, java.util.concurrent.Executor executor, boolean requireSubscribers)
public static FluxMessageChannelSpec flux()
public static FluxMessageChannelSpec flux(java.lang.String id)