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