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 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 |
queue(java.util.concurrent.BlockingQueue<org.springframework.messaging.Message<?>> 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.lang.String id) |
static QueueChannelSpec |
queue(java.lang.String id,
java.util.concurrent.BlockingQueue<org.springframework.messaging.Message<?>> queue) |
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 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.concurrent.BlockingQueue<org.springframework.messaging.Message<?>> queue)
public static QueueChannelSpec queue(java.lang.String id, java.util.concurrent.BlockingQueue<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 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)