クラス AmqpMessageSource

方法の詳細

• isTransacted

  protected boolean isTransacted()

• setTransacted

  public void setTransacted(boolean transacted)

  ACK にトランザクションチャネルを使用するには、true に設定します。

  パラメーター:

  transacted - 取引された場合は true。

• getPropertiesConverter

  protected MessagePropertiesConverter getPropertiesConverter()

• setPropertiesConverter

  public void setPropertiesConverter(MessagePropertiesConverter propertiesConverter)

  カスタム MessagePropertiesConverter を設定して、デフォルトの DefaultMessagePropertiesConverter を置き換えます。

  パラメーター:

  propertiesConverter - コンバーター。

• getHeaderMapper

  protected AmqpHeaderMapper getHeaderMapper()

• setHeaderMapper

  public void setHeaderMapper(AmqpHeaderMapper headerMapper)

  カスタム AmqpHeaderMapper を設定して、デフォルトの DefaultAmqpHeaderMapper.inboundMapper() を置き換えます。

  パラメーター:

  headerMapper - ヘッダーマッパー。

• getMessageConverter

  protected MessageConverter getMessageConverter()

• setMessageConverter

  public void setMessageConverter(MessageConverter messageConverter)

  カスタム MessageConverter を設定して、デフォルトの SimpleMessageConverter を置き換えます。

  パラメーター:

  messageConverter - コンバーター。

• isRawMessageHeader

  protected boolean isRawMessageHeader()

• setRawMessageHeader

  public void setRawMessageHeader(boolean rawMessageHeader)

  true に設定すると、生の spring-amqp メッセージがキー AmqpMessageHeaderErrorMessageStrategy.AMQP_RAW_MESSAGE のヘッダーとして含まれ、呼び出し元がメッセージにアクセスしてエラーを処理できるようになります。生のメッセージも共通ヘッダー IntegrationMessageHeaderAccessor.SOURCE_DATA に追加されます。

  パラメーター:

  rawMessageHeader - ヘッダーを含める場合は true。

• getBatchingStrategy

  protected BatchingStrategy getBatchingStrategy()

• setBatchingStrategy

  public void setBatchingStrategy(BatchingStrategy batchingStrategy)

  メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。デフォルトは SimpleBatchingStrategy です。

  パラメーター:

  batchingStrategy - 戦略。

  導入:

  5.2

• getComponentType

  public StringSE getComponentType()

• doReceive

  protected @Nullable AbstractIntegrationMessageBuilder<ObjectSE> doReceive()

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

  サブクラスはこのメソッドを実装する必要があります。通常、返される値は型 T の payload になりますが、返される値はペイロードが型 T である Message インスタンスである場合もあります。また、追加のヘッダーの設定に使用される AbstractIntegrationMessageBuilder である場合もあります。

  次で指定:

  クラス AbstractMessageSource<ObjectSE> の doReceive 

  戻り値:

  返された値。