public class Channels
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
AmqpMessageChannelSpec<? extends AmqpMessageChannelSpec<?>> |
amqp(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
AmqpMessageChannelSpec<? extends AmqpMessageChannelSpec<?>> |
amqp(java.lang.String id,
org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
AmqpPollableMessageChannelSpec<? extends AmqpPollableMessageChannelSpec<?>> |
amqpPollable(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
AmqpPollableMessageChannelSpec<? extends AmqpPollableMessageChannelSpec<?>> |
amqpPollable(java.lang.String id,
org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
static AmqpPublishSubscribeMessageChannelSpec |
amqpPublishSubscribe(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
static AmqpPublishSubscribeMessageChannelSpec |
amqpPublishSubscribe(java.lang.String id,
org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
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) |
JmsMessageChannelSpec<? extends JmsMessageChannelSpec<?>> |
jms(javax.jms.ConnectionFactory connectionFactory) |
JmsMessageChannelSpec<? extends JmsMessageChannelSpec<?>> |
jms(java.lang.String id,
javax.jms.ConnectionFactory connectionFactory) |
JmsPollableMessageChannelSpec<? extends JmsPollableMessageChannelSpec<?>> |
jmsPollable(javax.jms.ConnectionFactory connectionFactory) |
JmsPollableMessageChannelSpec<? extends JmsPollableMessageChannelSpec<?>> |
jmsPollable(java.lang.String id,
javax.jms.ConnectionFactory connectionFactory) |
JmsPublishSubscribeMessageChannelSpec |
jmsPublishSubscribe(javax.jms.ConnectionFactory connectionFactory) |
JmsPublishSubscribeMessageChannelSpec |
jmsPublishSubscribe(java.lang.String id,
javax.jms.ConnectionFactory connectionFactory) |
PriorityChannelSpec |
priority() |
QueueChannelSpec.MessageStoreSpec |
priority(org.springframework.integration.store.PriorityCapableChannelMessageStore messageGroupStore,
java.lang.Object groupId) |
PriorityChannelSpec |
priority(java.lang.String id) |
QueueChannelSpec.MessageStoreSpec |
priority(java.lang.String id,
org.springframework.integration.store.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(org.springframework.integration.store.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,
org.springframework.integration.store.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(org.springframework.integration.store.ChannelMessageStore messageGroupStore, java.lang.Object groupId)
public QueueChannelSpec.MessageStoreSpec queue(java.lang.String id, org.springframework.integration.store.ChannelMessageStore messageGroupStore, java.lang.Object groupId)
public PriorityChannelSpec priority()
public PriorityChannelSpec priority(java.lang.String id)
public QueueChannelSpec.MessageStoreSpec priority(java.lang.String id, org.springframework.integration.store.PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId)
public QueueChannelSpec.MessageStoreSpec priority(org.springframework.integration.store.PriorityCapableChannelMessageStore messageGroupStore, java.lang.Object groupId)
public RendezvousChannelSpec rendezvous()
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 AmqpPollableMessageChannelSpec<? extends AmqpPollableMessageChannelSpec<?>> amqpPollable(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public AmqpPollableMessageChannelSpec<? extends AmqpPollableMessageChannelSpec<?>> amqpPollable(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public AmqpMessageChannelSpec<? extends AmqpMessageChannelSpec<?>> amqp(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public AmqpMessageChannelSpec<? extends AmqpMessageChannelSpec<?>> amqp(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public static AmqpPublishSubscribeMessageChannelSpec amqpPublishSubscribe(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public static AmqpPublishSubscribeMessageChannelSpec amqpPublishSubscribe(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public JmsPollableMessageChannelSpec<? extends JmsPollableMessageChannelSpec<?>> jmsPollable(javax.jms.ConnectionFactory connectionFactory)
public JmsPollableMessageChannelSpec<? extends JmsPollableMessageChannelSpec<?>> jmsPollable(java.lang.String id, javax.jms.ConnectionFactory connectionFactory)
public JmsMessageChannelSpec<? extends JmsMessageChannelSpec<?>> jms(javax.jms.ConnectionFactory connectionFactory)
public JmsMessageChannelSpec<? extends JmsMessageChannelSpec<?>> jms(java.lang.String id, javax.jms.ConnectionFactory connectionFactory)
public JmsPublishSubscribeMessageChannelSpec jmsPublishSubscribe(javax.jms.ConnectionFactory connectionFactory)
public JmsPublishSubscribeMessageChannelSpec jmsPublishSubscribe(java.lang.String id, javax.jms.ConnectionFactory connectionFactory)