public class AmqpPublishSubscribeMessageChannelSpec extends AmqpMessageChannelSpec<AmqpPublishSubscribeMessageChannelSpec>
adviceChainamqpChannelFactoryBeanchannelPARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| Modifier | Constructor and Description |
|---|---|
protected |
AmqpPublishSubscribeMessageChannelSpec(ConnectionFactory connectionFactory) |
| Modifier and Type | Method and Description |
|---|---|
AmqpPublishSubscribeMessageChannelSpec |
exchange(FanoutExchange exchange) |
acknowledgeMode, advice, autoStartup, batchSize, concurrentConsumers, doGet, errorHandler, exposeListenerChannel, maxSubscribers, phase, prefetchCount, receiveTimeout, recoveryInterval, shutdownTimeout, taskExecutor, transactionAttribute, transactionManageramqpMessageConverter, channelTransacted, defaultDeliveryMode, encoding, extractPayload, headersMappedLast, id, inboundHeaderMapper, messagePropertiesConverter, outboundHeaderMapper, queueName, templateChannelTransacteddatatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletonprotected AmqpPublishSubscribeMessageChannelSpec(ConnectionFactory connectionFactory)
public AmqpPublishSubscribeMessageChannelSpec exchange(FanoutExchange exchange)
exchange - the exchange.AmqpChannelFactoryBean.setExchange(FanoutExchange)