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