クラス ErrorMessagePublisher

java.lang.ObjectSE
org.springframework.integration.core.ErrorMessagePublisher
実装されたすべてのインターフェース:
Aware, BeanFactoryAware
既知の直属サブクラス
ErrorMessageSendingRecoverer、KafkaErrorSendingMessageRecoverer、MessagePublishingErrorHandler
public class ErrorMessagePublisher extends ObjectSE implements BeanFactoryAware
エラー公開の汎用として使用できるコンポーネント。エラー処理または再試行のシナリオで呼び出しまたは拡張できます。

ErrorMessageStrategy を使用して、AttributeAccessor（または他の publish() メソッドを使用する場合はメッセージおよび / またはスロー可能）に基づいてターゲット ErrorMessage のカスタマイズを提供できます。

導入:
4.3.10
作成者:
Artem Bilan, Gary Russell

  • フィールドの詳細

    • logger

      protected final Log logger

    • messagingTemplate

      protected final MessagingTemplate messagingTemplate

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

    • ErrorMessagePublisher

      public ErrorMessagePublisher()

  • メソッドの詳細

    • setErrorMessageStrategy

      public final void setErrorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)

    • setChannel

      public final void setChannel(MessageChannel channel)

    • setChannelName

      public void setChannelName(StringSE channelName)

    • getErrorMessageStrategy

      public ErrorMessageStrategy getErrorMessageStrategy()

    • getChannel

      public MessageChannel getChannel()

    • setSendTimeout

      public final void setSendTimeout(long sendTimeout)

    • setChannelResolver

      public final void setChannelResolver(DestinationResolver<MessageChannel> channelResolver)

    • setBeanFactory

      public void setBeanFactory(BeanFactory beanFactory)
      次で指定:
      インターフェース BeanFactoryAware の setBeanFactory 

    • getMessagingTemplate

      protected MessagingTemplate getMessagingTemplate()

    • getChannelResolver

      @Nullable protected DestinationResolver<MessageChannel> getChannelResolver()

    • publish

      public void publish(MessagingException exception)
      提供された例外のエラーメッセージを公開します。
      パラメーター:
      exception - 例外。

    • publish

      public void publish(Message<?> failedMessage, ThrowableSE throwable)
      提供されたメッセージとスロー可能メッセージのエラーメッセージを公開します。スロー可能オブジェクトがすでに failedMessage プロパティにメッセージを含む MessagingException である場合は、代わりに publish(MessagingException) を使用してください。
      パラメーター:
      failedMessage - メッセージ。
      throwable - スローアブル。

    • publish

      public void publish(Message<?> inputMessage, MessagingException exception)
      提供された例外のエラーメッセージを公開します。
      パラメーター:
      inputMessage - サブフローを開始したメッセージ。
      exception - 例外。

    • publish

      public void publish(@Nullable Message<?> inputMessage, Message<?> failedMessage, ThrowableSE throwable)
      提供されたメッセージとスロー可能メッセージのエラーメッセージを公開します。スロー可能オブジェクトがすでに failedMessage プロパティにメッセージを含む MessagingException である場合は、代わりに publish(MessagingException) を使用してください。
      パラメーター:
      inputMessage - サブフローを開始したメッセージ。
      failedMessage - メッセージ。
      throwable - スローアブル。

    • publish

      public void publish(ThrowableSE throwable, AttributeAccessor context)
      提供されたスロー可能オブジェクトとコンテキストのエラーメッセージを公開します。errorMessageStrategy は、公開する ErrorMessage を構築するために使用されます。
      パラメーター:
      throwable - スローアブル。null の可能性があります。
      context - ErrorMessage プロパティのコンテキスト。

    • determinePayload

      protected ThrowableSE determinePayload(ThrowableSE throwable, AttributeAccessor context)
      将来の ErrorMessage 用に Throwable payload を構築します。
      パラメーター:
      throwable - ErrorMessage ペイロードを判別するためのエラー。null にすることができます。
      context - エラーのコンテキスト。
      戻り値:
      ErrorMessage ペイロードのスロー可能
      関連事項:

    • payloadWhenNull

      protected ThrowableSE payloadWhenNull(AttributeAccessor context)
      元の Throwable がある場合、将来の ErrorMessage に提供されたコンテキストに基づいて Throwable payload を構築します。
      パラメーター:
      context - 例外プロパティに使用する AttributeAccessor
      戻り値:
      ErrorMessage ペイロードの Throwable 
      関連事項: