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