クラス JmsDestinationPollingSource

java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<ObjectSE>
org.springframework.integration.jms.inbound.JmsDestinationPollingSource
実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, MessageSource<ObjectSE>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement
public class JmsDestinationPollingSource extends AbstractMessageSource<ObjectSE>
ポーリングリスナーで JMS メッセージを受信するためのソース。このソースは、メッセージ量が非常に少ない場合にのみ推奨されます。それ以外の場合は、Spring の MessageListener コンテナーサポートを使用する JmsMessageDrivenEndpoint の方が適しています。
導入:
7.0
作成者:
Mark Fisher, Oleg Zhurakousky, Artem Bilan

  • コンストラクターの詳細

    • JmsDestinationPollingSource

      public JmsDestinationPollingSource(JmsTemplate jmsTemplate)

  • 方法の詳細

    • setDestination

      public void setDestination(DestinationEE destination)

    • setDestinationName

      public void setDestinationName(StringSE destinationName)

    • setExtractPayload

      public void setExtractPayload(boolean extractPayload)
      JMS メッセージから body を抽出するか、受信した JMS メッセージを Message payload として使用するかを示すフラグ。
      パラメーター:
      extractPayload - ブールフラグ。デフォルトは true です。
      導入:
      3.0.7

    • getComponentType

      public StringSE getComponentType()

    • setMessageSelector

      public void setMessageSelector(StringSE messageSelector)
      メッセージの受信時に使用する JMS メッセージセレクタ式を指定します。
      パラメーター:
      messageSelector - メッセージセレクター。

    • setHeaderMapper

      public void setHeaderMapper(JmsHeaderMapper headerMapper)

    • setSessionAcknowledgeMode

      public void setSessionAcknowledgeMode(StringSE sessionAcknowledgeMode)

    • onInit

      protected void onInit()
      オーバーライド:
      クラス AbstractExpressionEvaluator の onInit 

    • doReceive

      protected @Nullable ObjectSE doReceive()
      変換して Spring Integration Message として返す JMS MessageEE を受け取ります。このメソッドは、現在の JmsHeaderMapper インスタンスを使用して、JMS プロパティを MessageHeaders にマップします。
      次で指定:
      クラス AbstractMessageSource<ObjectSE> の doReceive 
      戻り値:
      返された値。