クラス NotificationPublishingMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.jmx.NotificationPublishingMessageHandler
実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、MessageHandler、reactor.core.CoreSubscriber<Message<?>>
public class NotificationPublishingMessageHandler extends AbstractMessageHandler
受信メッセージを JMX NotificationSE として公開するための AbstractMessageHandler 実装。OutboundMessageMapper は、Message を NotificationSE に変換するために使用されます。
導入:
2.0
作成者:
Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan, Trung Pham, Ngoc Nhan

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

    • NotificationPublishingMessageHandler

      public NotificationPublishingMessageHandler(ObjectNameSE objectName)
      指定されたオブジェクト名に基づいてインスタンスを構築します。
      パラメーター:
      objectName - 通知に使用する ObjectNameSE。

    • NotificationPublishingMessageHandler

      public NotificationPublishingMessageHandler(StringSE objectName)
      指定されたオブジェクト名に基づいてインスタンスを構築します。
      パラメーター:
      objectName - 通知に使用するオブジェクト名。

  • メソッドの詳細

    • setNotificationMapper

      public void setNotificationMapper(@Nullable OutboundMessageMapper<NotificationSE> notificationMapper)
      メッセージから通知を作成するためのマッパーを設定します。指定されていない場合は、デフォルトの実装が使用され、文字列型のペイロードは通知の「メッセージ」として渡され、他のすべてのペイロード型は通知の "userData" として渡されます。
      パラメーター:
      notificationMapper - 通知マッパー。

    • setDefaultNotificationType

      public void setDefaultNotificationType(StringSE defaultNotificationType)
      明示的な通知マッパーが構成されていない場合にデフォルトで使用する通知型を表すドット区切りの文字列を指定します。指定しない場合、通知にマップされる各メッセージに通知型のヘッダーが必要になります。
      パラメーター:
      defaultNotificationType - デフォルトの通知型。

    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponent の getComponentType 
      オーバーライド:
      クラス MessageHandlerSupport の getComponentType 

    • onInit

      public final void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス IntegrationObjectSupport の onInit 

    • handleMessageInternal

      protected void handleMessageInternal(Message<?> message)
      次で指定:
      クラス AbstractMessageHandler の handleMessageInternal