Class Channels
java.lang.Object
org.springframework.integration.dsl.Channels
- Since:
- 5.0
- Author:
- Artem Bilan, Gary Russell
-
Method Summary
Modifier and TypeMethodDescriptiondirect()
flux()
priority()
priority
(String id, PriorityCapableChannelMessageStore messageGroupStore, Object groupId) priority
(PriorityCapableChannelMessageStore messageGroupStore, Object groupId) publishSubscribe
(boolean requireSubscribers) publishSubscribe
(String id, boolean requireSubscribers) publishSubscribe
(String id, Executor executor) publishSubscribe
(String id, Executor executor, boolean requireSubscribers) publishSubscribe
(Executor executor) publishSubscribe
(Executor executor, boolean requireSubscribers) queue()
queue
(String id, ChannelMessageStore messageGroupStore, Object groupId) queue
(ChannelMessageStore messageGroupStore, Object groupId) rendezvous
(String id)
-
Method Details
-
direct
-
direct
-
queue
-
queue
-
queue
-
queue
-
queue
-
queue
-
queue
public QueueChannelSpec.MessageStoreSpec queue(ChannelMessageStore messageGroupStore, Object groupId) -
queue
public QueueChannelSpec.MessageStoreSpec queue(String id, ChannelMessageStore messageGroupStore, Object groupId) -
priority
-
priority
-
priority
public PriorityChannelSpec priority(String id, PriorityCapableChannelMessageStore messageGroupStore, Object groupId) -
rendezvous
-
priority
public PriorityChannelSpec priority(PriorityCapableChannelMessageStore messageGroupStore, Object groupId) -
rendezvous
-
publishSubscribe
-
publishSubscribe
-
publishSubscribe
-
publishSubscribe
public PublishSubscribeChannelSpec<?> publishSubscribe(Executor executor, boolean requireSubscribers) -
publishSubscribe
-
publishSubscribe
public PublishSubscribeChannelSpec<?> publishSubscribe(String id, Executor executor, boolean requireSubscribers) -
publishSubscribe
-
publishSubscribe
-
executor
-
executor
-
flux
-
flux
-