Class MessageChannels
java.lang.Object
org.springframework.integration.dsl.MessageChannels
public final class MessageChannels
extends java.lang.Object
- Since:
- 5.0
-
Method Summary
Modifier and Type Method Description static DirectChannelSpecdirect()static DirectChannelSpecdirect(java.lang.String id)static ExecutorChannelSpecexecutor(java.lang.String id, java.util.concurrent.Executor executor)static ExecutorChannelSpecexecutor(java.util.concurrent.Executor executor)static FluxMessageChannelSpecflux()static FluxMessageChannelSpecflux(java.lang.String id)static PriorityChannelSpecpriority()static PriorityChannelSpecpriority(java.lang.String id)static PriorityChannelSpecpriority(java.lang.String id, PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId)static PriorityChannelSpecpriority(PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId)static PublishSubscribeChannelSpec<?>publishSubscribe()static PublishSubscribeChannelSpec<?>publishSubscribe(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 PublishSubscribeChannelSpec<?>publishSubscribe(java.util.concurrent.Executor executor)static PublishSubscribeChannelSpec<?>publishSubscribe(java.util.concurrent.Executor executor, boolean requireSubscribers)static QueueChannelSpecqueue()static QueueChannelSpecqueue(java.lang.Integer capacity)static QueueChannelSpecqueue(java.lang.String id)static QueueChannelSpecqueue(java.lang.String id, java.lang.Integer capacity)static QueueChannelSpecqueue(java.lang.String id, java.util.Queue<org.springframework.messaging.Message<?>> queue)static QueueChannelSpec.MessageStoreSpecqueue(java.lang.String id, ChannelMessageStore messageGroupStore, java.lang.Object groupId)static QueueChannelSpecqueue(java.util.Queue<org.springframework.messaging.Message<?>> queue)static QueueChannelSpec.MessageStoreSpecqueue(ChannelMessageStore messageGroupStore, java.lang.Object groupId)static RendezvousChannelSpecrendezvous()static RendezvousChannelSpecrendezvous(java.lang.String id)
-
Method Details
-
direct
-
direct
-
queue
-
queue
-
queue
public static QueueChannelSpec queue(java.util.Queue<org.springframework.messaging.Message<?>> queue) -
queue
public static QueueChannelSpec queue(java.lang.String id, java.util.Queue<org.springframework.messaging.Message<?>> queue) -
queue
-
queue
-
queue
public static QueueChannelSpec.MessageStoreSpec queue(ChannelMessageStore messageGroupStore, java.lang.Object groupId) -
queue
public static QueueChannelSpec.MessageStoreSpec queue(java.lang.String id, ChannelMessageStore messageGroupStore, java.lang.Object groupId) -
executor
-
executor
public static ExecutorChannelSpec executor(java.lang.String id, java.util.concurrent.Executor executor) -
rendezvous
-
rendezvous
-
priority
-
priority
-
priority
public static PriorityChannelSpec priority(PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId) -
priority
public static PriorityChannelSpec priority(java.lang.String id, PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId) -
publishSubscribe
-
publishSubscribe
-
publishSubscribe
-
publishSubscribe
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.lang.String id, boolean requireSubscribers) -
publishSubscribe
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.util.concurrent.Executor executor) -
publishSubscribe
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.util.concurrent.Executor executor, boolean requireSubscribers) -
publishSubscribe
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.lang.String id, java.util.concurrent.Executor executor) -
publishSubscribe
public static PublishSubscribeChannelSpec<?> publishSubscribe(java.lang.String id, java.util.concurrent.Executor executor, boolean requireSubscribers) -
flux
-
flux
-