S - ターゲット AmqpBaseOutboundEndpointSpec 実装型。E - ターゲット AbstractAmqpOutboundEndpoint 実装型。public abstract class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends AbstractAmqpOutboundEndpoint> extends MessageHandlerSpec<S,E>
| 修飾子と型 | フィールドと説明 |
|---|---|
protected DefaultAmqpHeaderMapper | headerMapper |
PARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| コンストラクターと説明 |
|---|
AmqpBaseOutboundEndpointSpec() |
| 修飾子と型 | メソッドと説明 |
|---|---|
S | confirmAckChannel(MessageChannel ackChannel)Ack が送信されるチャネルを設定します(パブリッシャーが確認します)。 |
S | confirmCorrelationExpression(Expression confirmCorrelationExpression)SpEL 式を設定して、実行時に確認相関を評価します。 |
S | confirmCorrelationExpression(StringSE confirmCorrelationExpression)SpEL 式を設定して、実行時に確認相関を評価します。 |
S | confirmCorrelationFunction(java.util.function.FunctionSE<Message<?>,ObjectSE> confirmCorrelationFunction)FunctionSE を設定して、実行時に相関関係を確認することを評価します。 |
S | confirmNackChannel(MessageChannel nackChannel) ナックが送信されるチャネルを設定します(パブリッシャーが確認します)。 |
S | confirmTimeout(long timeout) その時間内にパブリッシャーの確認が受信されなかった場合、nack が合成されるまでのタイムアウトを設定します。 |
S | defaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode) デフォルトの配信モードを設定します。 |
S | delay(int delay)RabbitMQ 遅延メッセージ交換プラグインを使用する場合、 x-delay ヘッダーに設定する値を設定します。 |
S | delayExpression(Expression delayExpression)RabbitMQ 遅延メッセージ交換プラグインを使用する場合、 x-delay ヘッダーを計算するように SpEL 式を設定します。 |
S | delayExpression(StringSE delayExpression)RabbitMQ 遅延メッセージ交換プラグインを使用する場合、 x-delay ヘッダーを計算するように SpEL 式を設定します。 |
S | delayFunction(java.util.function.FunctionSE<Message<?>,IntegerSE> delayFunction)RabbitMQ 遅延メッセージ交換プラグインを使用するときに x-delay ヘッダーを計算する関数を設定します。 |
S | errorMessageStrategy(ErrorMessageStrategy errorMessageStrategy) 返される(または否定的に確認された)メッセージに使用するエラーメッセージ戦略を設定します。 |
S | exchangeName(StringSE exchangeName) メッセージを送信するための AMQP 交換名を構成します。 |
S | exchangeNameExpression(Expression exchangeNameExpression) 実行時に交換名を評価するように SpEL 式を構成します。 |
S | exchangeNameExpression(StringSE exchangeNameExpression) 実行時に交換名を評価するように SpEL 式を構成します。 |
S | exchangeNameFunction(java.util.function.FunctionSE<Message<?>,StringSE> exchangeNameFunction) 実行時に交換名を評価するように FunctionSE を構成します。 |
S | headerMapper(AmqpHeaderMapper headerMapper) リクエストおよび応答ヘッダーをマッピングするためのカスタム AmqpHeaderMapper を設定します。 |
S | headersMappedLast(boolean headersLast) メッセージが変換される前にヘッダーがマップされるか、後でマップされるかを決定します。 |
S | lazyConnect(boolean lazyConnect) エンドポイントの開始時に接続を試行するには、 false に設定します。 |
S | mappedReplyHeaders(StringSE... headers)MessageHeaders からのレスポンスにマップする必要があるヘッダー名を指定します。 |
S | mappedRequestHeaders(StringSE... headers) リクエストから MessageHeaders にマップする必要のあるヘッダー名を指定します。 |
S | returnChannel(MessageChannel returnChannel) 返されたメッセージが送信されるチャネルを設定します。 |
S | routingKey(StringSE routingKey) メッセージを送信するための AMQP ルーティングキーを構成します。 |
S | routingKeyExpression(Expression routingKeyExpression) 実行時にルーティングキーを評価するための SpEL 式。 |
S | routingKeyExpression(StringSE routingKeyExpression) 実行時にルーティングキーを評価するための SpEL 式。 |
S | routingKeyFunction(java.util.function.FunctionSE<Message<?>,StringSE> routingKeyFunction) 実行時にルーティングキーを評価する関数。 |
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, 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
public S headerMapper(AmqpHeaderMapper headerMapper)
AmqpHeaderMapper を設定します。headerMapper - 使用する AmqpHeaderMapper。public S defaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)
defaultDeliveryMode - 配信モード。public S routingKey(StringSE routingKey)
routingKey - 使用するルーティングキー public S routingKeyExpression(StringSE routingKeyExpression)
routingKeyExpression - 使用する式。public S routingKeyFunction(java.util.function.FunctionSE<Message<?>,StringSE> routingKeyFunction)
routingKeyFunction - 使用する FunctionSE。public S routingKeyExpression(Expression routingKeyExpression)
routingKeyExpression - 使用する式。public S returnChannel(MessageChannel returnChannel)
returnChannel - チャンネル。public S confirmAckChannel(MessageChannel ackChannel)
ackChannel - チャンネル。public S exchangeName(StringSE exchangeName)
exchangeName - メッセージを送信するための交換名。public S exchangeNameExpression(StringSE exchangeNameExpression)
exchangeNameExpression - 使用する式。public S exchangeNameFunction(java.util.function.FunctionSE<Message<?>,StringSE> exchangeNameFunction)
FunctionSE を構成します。exchangeNameFunction - 使用する関数。public S exchangeNameExpression(Expression exchangeNameExpression)
exchangeNameExpression - 使用する式。public S confirmNackChannel(MessageChannel nackChannel)
nackChannel - チャンネル。public S confirmCorrelationExpression(StringSE confirmCorrelationExpression)
confirmCorrelationExpression - 使用する式。public S confirmCorrelationFunction(java.util.function.FunctionSE<Message<?>,ObjectSE> confirmCorrelationFunction)
FunctionSE を設定して、実行時に相関関係を確認することを評価します。confirmCorrelationFunction - 使用する関数。public S confirmCorrelationExpression(Expression confirmCorrelationExpression)
confirmCorrelationExpression - 使用する式。public S mappedRequestHeaders(StringSE... headers)
MessageHeaders にマップする必要のあるヘッダー名を指定します。headers - リクエストヘッダー名。public S mappedReplyHeaders(StringSE... headers)
MessageHeaders からのレスポンスにマップする必要があるヘッダー名を指定します。headers - 応答ヘッダー名。public S headersMappedLast(boolean headersLast)
headersLast - ヘッダーを最後にマップする場合は true。AbstractAmqpOutboundEndpoint.setHeadersMappedLast(boolean)public S lazyConnect(boolean lazyConnect)
false に設定します。lazyConnect - lazyConnect を設定します。AbstractAmqpOutboundEndpoint.setLazyConnect(boolean)public S delay(int delay)
x-delay ヘッダーに設定する値を設定します。delay - 遅延。AbstractAmqpOutboundEndpoint.setDelay(int)public S delayFunction(java.util.function.FunctionSE<Message<?>,IntegerSE> delayFunction)
x-delay ヘッダーを計算する関数を設定します。delayFunction - x-delay ヘッダーの値を評価する関数。delayExpression(Expression)public S delayExpression(Expression delayExpression)
x-delay ヘッダーを計算するように SpEL 式を設定します。delayExpression - 表現。AbstractAmqpOutboundEndpoint.setDelayExpression(Expression)public S delayExpression(StringSE delayExpression)
x-delay ヘッダーを計算するように SpEL 式を設定します。delayExpression - 表現。AbstractAmqpOutboundEndpoint.setDelayExpressionString(String)public S errorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)
errorMessageStrategy - 戦略。AbstractAmqpOutboundEndpoint.setErrorMessageStrategy(ErrorMessageStrategy)public S confirmTimeout(long timeout)
timeout - おおよそのタイムアウト。