パッケージ org.springframework.integration.channel.interceptor

クラス WireTap

java.lang.ObjectSE
org.springframework.integration.channel.interceptor.WireTap
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、Lifecycle、VetoCapableInterceptor、ManageableLifecycle、ChannelInterceptor
@ManagedResource public class WireTap extends ObjectSE implements ChannelInterceptor, ManageableLifecycle, VetoCapableInterceptor, BeanFactoryAware
元のメッセージをメインチャネルに送信しながら、インターセプトしたメッセージのコピーをセカンダリターゲットに公開する ChannelInterceptor。
作成者:
Mark Fisher, Gary Russell, Artem Bilan

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

    • WireTap

      public WireTap(MessageChannel channel)
      MessageSelector のない新しいワイヤータップを作成します。
      パラメーター:
      channel - インターセプトされたメッセージの送信先となる MessageChannel

    • WireTap

      public WireTap(MessageChannel channel, MessageSelector selector)
      付属の MessageSelector を使用して新しいワイヤータップを作成します。
      パラメーター:
      channel - インターセプトされたメッセージが送信されるチャネル
      selector - メッセージをインターセプトチャネルに送信するためにメッセージを受け入れる必要があるセレクター

    • WireTap

      public WireTap(StringSE channelName)
      MessageChannel 名に基づいて、MessageSelector を使用せずに新しいワイヤータップを作成します。
      パラメーター:
      channelName - インターセプトされたメッセージの送信先となるターゲット MessageChannel の名前
      導入:
      4.3

    • WireTap

      public WireTap(StringSE channelName, MessageSelector selector)
      付属の MessageSelector を使用して新しいワイヤータップを作成します。
      パラメーター:
      channelName - インターセプトされたメッセージの送信先となるターゲット MessageChannel の名前。
      selector - メッセージをインターセプトチャネルに送信するためにメッセージを受け入れる必要があるセレクター
      導入:
      4.3

  • メソッドの詳細

    • setTimeout

      public void setTimeout(long timeout)
      インターセプトするターゲットに送信するためのタイムアウト値を指定します。
      パラメーター:
      timeout - ミリ秒単位のタイムアウト

    • setBeanFactory

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

    • isRunning

      @ManagedAttribute public boolean isRunning()
      盗聴が現在実行されているかどうかを確認します。
      次で指定:
      インターフェース Lifecycle の isRunning 
      次で指定:
      インターフェース ManageableLifecycle の isRunning 

    • start

      @ManagedOperation public void start()
      ワイヤータップが停止している場合は、ワイヤータップを再開します。デフォルトで実行されています。
      次で指定:
      インターフェース Lifecycle の start 
      次で指定:
      インターフェース ManageableLifecycle の start 

    • stop

      @ManagedOperation public void stop()
      ワイヤータップを停止します。再起動するには、start() を呼び出します。
      次で指定:
      インターフェース Lifecycle の stop 
      次で指定:
      インターフェース ManageableLifecycle の stop 

    • preSend

      public Message<?> preSend(Message<?> message, MessageChannel channel)
      メッセージをインターセプトし、MessageSelector によって受け入れられた場合は、セカンダリターゲットに送信します。この盗聴者の MessageSelector が null の場合、すべてのメッセージを受け入れます。
      次で指定:
      インターフェース ChannelInterceptor の preSend 

    • shouldIntercept

      public boolean shouldIntercept(StringSE beanName, InterceptableChannel channel)
      次で指定:
      インターフェース VetoCapableInterceptor の shouldIntercept 
      パラメーター:
      beanName - チャンネル名。
      channel - インターセプトされようとしているチャネル。
      戻り値:
      インターセプトがインターセプトを拒否したい場合は false。