S - ターゲット AmqpPollableMessageChannelSpec 実装型。public class AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel> extends MessageChannelSpec<S,T>
| 修飾子と型 | フィールドと説明 |
|---|---|
protected AmqpChannelFactoryBean | amqpChannelFactoryBean |
channelPARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子 | コンストラクターと説明 |
|---|---|
protected | AmqpPollableMessageChannelSpec(ConnectionFactory connectionFactory) |
| 修飾子と型 | メソッドと説明 |
|---|---|
S | amqpMessageConverter(MessageConverter messageConverter) |
S | channelTransacted(boolean channelTransacted)Spring Integration 4.0 を使用する場合は、 RabbitTemplate(送信用)と SimpleMessageListenerContainer(受信用)の両方で channelTransacted を構成します。 |
S | defaultDeliveryMode(MessageDeliveryMode mode)AmqpHeaders.DELIVERY_MODE ヘッダーを持たないメッセージの配信モードを構成します。 |
protected T | doGet() |
S | encoding(StringSE encoding) |
S | extractPayload(boolean extract) 通常の spring-messaging から AMQP へのメッセージマッピングを有効にするかどうかを設定します。 |
S | headersMappedLast(boolean headersLast) |
protected S | id(StringSE id) コンポーネント識別子を構成します。 |
S | inboundHeaderMapper(AmqpHeaderMapper mapper)extractPayload(boolean) が true の場合に使用する受信ヘッダーマッパーを構成します。 |
S | messagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter) |
S | outboundHeaderMapper(AmqpHeaderMapper mapper)extractPayload(boolean) が true の場合に使用する送信ヘッダーマッパーを構成します。 |
S | queueName(StringSE queueName) また、 id(String) を暗黙的に設定します(明示的に設定されていない場合)。 |
S | templateChannelTransacted(boolean channelTransacted) チャネルにメッセージを送信するときに使用される RabbitTemplate で channelTransacted を構成します。 |
datatype, 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, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected final AmqpChannelFactoryBean amqpChannelFactoryBean
protected AmqpPollableMessageChannelSpec(ConnectionFactory connectionFactory)
protected S id(@Nullable StringSE id)
IntegrationComponentSpecbeanName として使用されます。IntegrationComponentSpec<S extends AmqpPollableMessageChannelSpec<S, T>,T extends AbstractAmqpChannel> の id id - ID。public S queueName(StringSE queueName)
id(String) を暗黙的に設定します(明示的に設定されていない場合)。queueName - queueName。AmqpChannelFactoryBean.setQueueName(String)public S encoding(StringSE encoding)
encoding - エンコーディング。RabbitTemplate.setEncoding(String)public S amqpMessageConverter(MessageConverter messageConverter)
messageConverter - messageConverter。RabbitTemplate.setMessageConverter(MessageConverter)public S channelTransacted(boolean channelTransacted)
RabbitTemplate(送信用)と SimpleMessageListenerContainer(受信用)の両方で channelTransacted を構成します。Spring Integration 4.1 を使用する場合、コンテナーのみが構成されます。templateChannelTransacted(boolean) を参照してください。channelTransacted - channelTransacted。RabbitAccessor.setChannelTransacted(boolean), RabbitAccessor.setChannelTransacted(boolean)public S templateChannelTransacted(boolean channelTransacted)
RabbitTemplate で channelTransacted を構成します。Spring Integration 4.1 以上が使用されている場合にのみ適用されます。それ以外の場合は、channelTransacted(boolean) を参照してください。channelTransacted - channelTransacted。RabbitAccessor.setChannelTransacted(boolean)public S messagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)
messagePropertiesConverter - messagePropertiesConverter。RabbitTemplate.setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter), AbstractMessageListenerContainer.setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter)public S defaultDeliveryMode(MessageDeliveryMode mode)
AmqpHeaders.DELIVERY_MODE ヘッダーを持たないメッセージの配信モードを構成します。デフォルトは MessageDeliveryMode.PERSISTENT です。mode - モード。public S extractPayload(boolean extract)
extract - マッピングを有効にするには true。outboundHeaderMapper(AmqpHeaderMapper), inboundHeaderMapper(AmqpHeaderMapper)public S outboundHeaderMapper(AmqpHeaderMapper mapper)
extractPayload(boolean) が true の場合に使用する送信ヘッダーマッパーを構成します。デフォルトは DefaultAmqpHeaderMapper です。mapper - マッパー。extractPayload(boolean)public S inboundHeaderMapper(AmqpHeaderMapper mapper)
extractPayload(boolean) が true の場合に使用する受信ヘッダーマッパーを構成します。デフォルトは DefaultAmqpHeaderMapper です。mapper - マッパー。extractPayload(boolean)public S headersMappedLast(boolean headersLast)
headersLast - ヘッダーを最後にマップする場合は true。AbstractAmqpChannel.setHeadersMappedLast(boolean)protected T doGet()
MessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S, T>,T extends AbstractAmqpChannel> の doGet