S
- ターゲット AmqpPollableMessageChannelSpec
実装型。public class AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel> extends MessageChannelSpec<S,T>
修飾子と型 | フィールドと説明 |
---|---|
protected AmqpChannelFactoryBean | amqpChannelFactoryBean |
channel
PARSER, target
logger
DEFAULT_PHASE
OBJECT_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, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
protected final AmqpChannelFactoryBean amqpChannelFactoryBean
protected AmqpPollableMessageChannelSpec(ConnectionFactory connectionFactory)
protected S id(@Nullable StringSE id)
IntegrationComponentSpec
beanName
として使用されます。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