Package org.springframework.integration.amqp.dsl

Class AmqpPublishSubscribeMessageChannelSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,C>

org.springframework.integration.dsl.MessageChannelSpec<S,T>

org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec<S,T>

org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec<AmqpPublishSubscribeMessageChannelSpec,PollableAmqpChannel>

org.springframework.integration.amqp.dsl.AmqpPublishSubscribeMessageChannelSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<PollableAmqpChannel>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

public class AmqpPublishSubscribeMessageChannelSpec
extends AmqpMessageChannelSpec<AmqpPublishSubscribeMessageChannelSpec,PollableAmqpChannel>

A AmqpMessageChannelSpec for PublishSubscribeAmqpChannels.

Since:

5.0

Author:

Artem Bilan, Artem Vozhdayenko

Field Summary

Fields inherited from class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec

adviceChain

Fields inherited from class org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec

amqpChannelFactoryBean

Fields inherited from class org.springframework.integration.dsl.MessageChannelSpec

channel

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AmqpPublishSubscribeMessageChannelSpec(ConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method	Description
AmqpPublishSubscribeMessageChannelSpec	exchange(FanoutExchange exchange)

Methods inherited from class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec

acknowledgeMode, advice, autoStartup, batchSize, concurrentConsumers, doGet, errorHandler, exposeListenerChannel, maxSubscribers, phase, prefetchCount, receiveTimeout, recoveryInterval, shutdownTimeout, taskExecutor, transactionAttribute, transactionManager

Methods inherited from class org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec

amqpMessageConverter, channelTransacted, defaultDeliveryMode, encoding, extractPayload, headersMappedLast, id, inboundHeaderMapper, messagePropertiesConverter, outboundHeaderMapper, queueName, templateChannelTransacted

Methods inherited from class org.springframework.integration.dsl.MessageChannelSpec

datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, get, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Constructor Details

AmqpPublishSubscribeMessageChannelSpec

protected AmqpPublishSubscribeMessageChannelSpec(ConnectionFactory connectionFactory)

Method Details

exchange

public AmqpPublishSubscribeMessageChannelSpec exchange(FanoutExchange exchange)

Parameters:

exchange - the exchange.

Returns:

the spec.

See Also:

• AmqpChannelFactoryBean.setExchange(FanoutExchange)