S - ターゲット AmqpBaseInboundGatewaySpec 実装型。public class AmqpBaseInboundGatewaySpec<S extends AmqpBaseInboundGatewaySpec<S>> extends MessagingGatewaySpec<S,AmqpInboundGateway>
AmqpInboundGateway| 修飾子と型 | フィールドと説明 |
|---|---|
protected DefaultAmqpHeaderMapper | headerMapper |
PARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子 | コンストラクターと説明 |
|---|---|
protected | AmqpBaseInboundGatewaySpec(AmqpInboundGateway gateway) |
| 修飾子と型 | メソッドと説明 |
|---|---|
S | batchingStrategy(BatchingStrategy batchingStrategy) メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。 |
S | bindSourceMessage(boolean bindSourceMessage)true に設定すると、ヘッダーのソースメッセージがバインドされます。 |
S | defaultReplyTo(StringSE defaultReplyTo) 次の形式の
defaultReplyTo アドレス (exchange)/(routingKey) |
S |
headerMapper(AmqpHeaderMapper headerMapper)
Configure the gateway's
AmqpHeaderMapper; defaults to
DefaultAmqpHeaderMapper. |
S |
mappedReplyHeaders(StringSE... headers)
Only applies if the default header mapper is used.
|
S |
mappedRequestHeaders(StringSE... headers)
Only applies if the default header mapper is used.
|
S |
messageConverter(MessageConverter messageConverter)
Configure the gateway's
MessageConverter;
defaults to SimpleMessageConverter. |
S |
recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
Set a
RecoveryCallback when using retry within the adapter. |
S |
replyHeadersMappedLast(boolean replyHeadersMappedLast)
When mapping headers for the outbound (reply) message, determine whether the headers are
mapped before the message is converted, or afterwards.
|
S |
retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
Set a
RetryTemplate to use for retrying a message delivery within the
adapter. |
autoStartup, errorChannel, errorChannel, errorOnTimeout, id, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout, shouldTrack_this, createInstance, destroyInstance, doGet, 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 DefaultAmqpHeaderMapper headerMapper
protected AmqpBaseInboundGatewaySpec(AmqpInboundGateway gateway)
public S messageConverter(MessageConverter messageConverter)
MessageConverter を構成します。; デフォルトは SimpleMessageConverter です。messageConverter - messageConverter。AmqpInboundGateway.setMessageConverter(org.springframework.amqp.support.converter.MessageConverter)public S headerMapper(AmqpHeaderMapper headerMapper)
AmqpHeaderMapper を構成します。; デフォルトは DefaultAmqpHeaderMapper です。headerMapper - headerMapper。AmqpInboundGateway.setHeaderMapper(AmqpHeaderMapper)public S mappedRequestHeaders(StringSE... headers)
headers - ヘッダー。AbstractHeaderMapper.setRequestHeaderNames(String[])public S mappedReplyHeaders(StringSE... headers)
headers - ヘッダー。AbstractHeaderMapper.setReplyHeaderNames(String[])public S defaultReplyTo(StringSE defaultReplyTo)
defaultReplyTo アドレス (exchange)/(routingKey)または
(queueName)リクエストメッセージに
replyTo プロパティがない場合。2 番目の形式は、デフォルトの交換（""）とキュー名をルーティングキーとして使用します。defaultReplyTo - 使用するデフォルトの replyTo アドレス。AmqpInboundGateway.setDefaultReplyTo(java.lang.String)public S retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
RetryTemplate を設定します。retryTemplate - テンプレート。AmqpInboundGateway.setRetryTemplate(RetryTemplate)public S recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
RecoveryCallback を設定します。recoveryCallback - コールバック。AmqpInboundGateway.setRecoveryCallback(RecoveryCallback)public S batchingStrategy(BatchingStrategy batchingStrategy)
batchingStrategy - 使用する戦略。AmqpInboundGateway.setBatchingStrategy(BatchingStrategy)public S bindSourceMessage(boolean bindSourceMessage)
bindSourceMessage - バインドする場合は true。AmqpInboundGateway.setBindSourceMessage(boolean)public S replyHeadersMappedLast(boolean replyHeadersMappedLast)
replyHeadersMappedLast - 変換後に応答ヘッダーがマップされる場合は true。AmqpInboundGateway.setReplyHeadersMappedLast(boolean)