クラス CharacterStreamWritingMessageHandler

実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>AwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanApplicationContextAwareOrderedExpressionCapableOrderableIntegrationPatternNamedComponentIntegrationManagementTrackableComponentMessageHandlerreactor.core.CoreSubscriber<Message<?>>

public class CharacterStreamWritingMessageHandler extends AbstractMessageHandler
WriterSE に文字を書き込む MessageHandler。文字列、文字配列、バイト配列のペイロードは直接書き込まれますが、他のペイロード型の場合は、オブジェクトの IntegrationObjectSupport.toString() メソッドの結果が書き込まれます。各書き込みの後に改行を追加するには、shouldAppendNewLine フラグを "true" に設定します。デフォルトでは "false" です。
作成者:
Mark Fisher, Gary Russell
  • コンストラクターの詳細

    • CharacterStreamWritingMessageHandler

      public CharacterStreamWritingMessageHandler(WriterSE writer)
    • CharacterStreamWritingMessageHandler

      public CharacterStreamWritingMessageHandler(WriterSE writer, int bufferSize)
  • メソッドの詳細

    • stdout

      public static CharacterStreamWritingMessageHandler stdout()
      デフォルトの文字セットエンコーディングを使用して stdout(System.out)のターゲットを作成するファクトリメソッド。
      戻り値:
      デフォルトの文字セットを持つ stdout ハンドラー。
    • stdout

      public static CharacterStreamWritingMessageHandler stdout(StringSE charsetName)
      指定された文字セットエンコーディングで stdout(System.out)のターゲットを作成するファクトリメソッド。
      パラメーター:
      charsetName - 文字セット名。
      戻り値:
      stdout ハンドラー。
    • stderr

      public static CharacterStreamWritingMessageHandler stderr()
      デフォルトの文字セットエンコーディングを使用して stderr(System.err)のターゲットを作成するファクトリメソッド。
      戻り値:
      デフォルトの文字セットを持つ stderr ハンドラー。
    • stderr

      public static CharacterStreamWritingMessageHandler stderr(StringSE charsetName)
      指定された文字セットエンコーディングで stderr(System.err)のターゲットを作成するファクトリメソッド。
      パラメーター:
      charsetName - 文字セット名。
      戻り値:
      stderr ハンドラー。
    • setShouldAppendNewLine

      public void setShouldAppendNewLine(boolean shouldAppendNewLine)
    • appendNewLine

      public CharacterStreamWritingMessageHandler appendNewLine(boolean append)
      setShouldAppendNewLine(boolean) 用の流れるような API。
      パラメーター:
      append - 改行を追加する場合は true。
      戻り値:
      this。
      導入:
      5.4
    • getComponentType

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

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