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(java.util.concurrent.Executor executor) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(java.lang.String id) |
static PublishSubscribeChannelSpec<?> |
publishSubscribe(java.lang.String id,
java.util.concurrent.Executor executor) |
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(java.lang.String id)
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.util.concurrent.Executor executor)
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.lang.String id, java.util.concurrent.Executor executor)
public static FluxMessageChannelSpec flux()
public static FluxMessageChannelSpec flux(java.lang.String id)