クラス AbstractAmqpChannel

メソッドの詳細

• isLoggingEnabled

  public boolean isLoggingEnabled()

  インターフェースからコピーされた説明: IntegrationManagement

  ロギングが有効かどうかを返します。

  次で指定:

  インターフェース IntegrationManagement の isLoggingEnabled 

  オーバーライド:

  クラス AbstractMessageChannel の isLoggingEnabled 

  戻り値:

  有効な場合は true。

• setLoggingEnabled

  public void setLoggingEnabled(boolean loggingEnabled)

  インターフェースからコピーされた説明: IntegrationManagement

  ロギングを有効にするかどうか。

  次で指定:

  インターフェース IntegrationManagement の setLoggingEnabled 

  オーバーライド:

  クラス AbstractMessageChannel の setLoggingEnabled 

  パラメーター:

  loggingEnabled - 無効にする場合は false。

• setDefaultDeliveryMode

  public void setDefaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)

  メッセージに "amqp_deliveryMode" ヘッダーがなく、メッセージプロパティが MessagePropertiesConverter によって設定されていない場合に使用する配信モードを設定します。

  パラメーター:

  defaultDeliveryMode - デフォルトの配信モード。

  導入:

  4.3

• setExtractPayload

  public void setExtractPayload(boolean extractPayload)

  true に設定すると、ペイロードが抽出され、ヘッダーがマップされます。それ以外の場合は、メッセージ全体が変換されて送信されます。デフォルトは false です。

  パラメーター:

  extractPayload - 抽出してマッピングするのは本当です。

  導入:

  4.3

• isExtractPayload

  protected boolean isExtractPayload()

  戻り値:

  抽出ペイロード。

  導入:

  4.3

  関連事項:

  • setExtractPayload(boolean)

• setHeadersMappedLast

  public void setHeadersMappedLast(boolean headersMappedLast)

  送信メッセージのヘッダーをマッピングする場合、ヘッダーをメッセージの変換前にマッピングするか、変換後にマッピングするかを決定します。これは、メッセージコンバーターによって追加される可能性のあるヘッダーにのみ影響します。false の場合、コンバーターのヘッダーが優先されます。true の場合、コンバーターによって追加されたヘッダーは上書きされます (ソースメッセージにそれらのヘッダーにマッピングされるヘッダーがある場合)。たとえば、JSON を含む文字列ペイロードで SimpleMessageConverter を使用する場合、これを true に設定すると、コンバーターはコンテンツ型を text/plain に設定しますが、これは AmqpHeaders.CONTENT_TYPE メッセージヘッダーを設定することで application/json に上書きできます。extractPayload が true の場合にのみ適用されます。既定値: false。

  パラメーター:

  headersMappedLast - 変換後にヘッダーがマップされる場合は true。

  導入:

  5.0

• getExchangeName

  protected StringSE getExchangeName()

  サブクラスはこのメソッドをオーバーライドして、Exchange 名を返す場合があります。デフォルトでは、メッセージは名前のない直接交換に送信されます。

  戻り値:

  エクスチェンジ名。

• getRoutingKey

  protected StringSE getRoutingKey()

  サブクラスは、このメソッドをオーバーライドしてルーティングキーを返す場合があります。デフォルトでは、ルーティングキー（空の文字列）はありません。

  戻り値:

  ルーティングキー。

• getInboundHeaderMapper

  protected AmqpHeaderMapper getInboundHeaderMapper()

• getAmqpTemplate

  protected AmqpTemplate getAmqpTemplate()

• getRabbitTemplate

  protected RabbitTemplate getRabbitTemplate()

• setAdmin

  protected final void setAdmin(AmqpAdmin admin)

• setConnectionFactory

  protected final void setConnectionFactory(ConnectionFactory connectionFactory)

• getAdmin

  protected AmqpAdmin getAdmin()

• getConnectionFactory

  protected ConnectionFactory getConnectionFactory()

• onInit

  protected void onInit()

  クラスからコピーされた説明: IntegrationObjectSupport

  サブクラスは、初期化ロジック用にこれを実装できます。

  オーバーライド:

  クラス AbstractMessageChannel の onInit 

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean の destroy 

  次で指定:

  インターフェース IntegrationManagement の destroy 

  オーバーライド:

  クラス AbstractMessageChannel の destroy 

• doSend

  protected boolean doSend(Message<?> message, long timeout)

  クラスからコピーされた説明: AbstractMessageChannel

  サブクラスはこのメソッドを実装する必要があります。負でないタイムアウトは、チャネルが容量に達した場合に待機する時間を示します（値が 0 の場合、成功の有無にかかわらずすぐに戻る必要があります）。負のタイムアウト値は、メッセージが受け入れられるか、ブロッキングスレッドが中断されるまでメソッドがブロックされることを示します。

  次で指定:

  クラス AbstractMessageChannel の doSend 

  パラメーター:

  message - メッセージ。

  timeout - タイムアウト。

  戻り値:

  send が成功した場合は true。

• onCreate

  public void onCreate(Connection connection)

  次で指定:

  インターフェース ConnectionListener の onCreate 

• doDeclares

  protected abstract void doDeclares()