クラス RedisQueueOutboundChannelAdapter

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

public class RedisQueueOutboundChannelAdapter extends AbstractMessageHandler
導入:
3.0
作成者:
Mark Fisher, Gunnar Hillert, Artem Bilan, Rainer Frey
  • コンストラクターの詳細

  • メソッドの詳細

    • setExtractPayload

      public void setExtractPayload(boolean extractPayload)
    • setSerializer

      public void setSerializer(RedisSerializer<?> serializer)
    • setLeftPush

      public void setLeftPush(boolean leftPush)
      Redis リストへの PUSH 操作を LPUSH にするか RPUSH にするかを指定します。
      パラメーター:
      leftPush - LPUSH フラグ。デフォルトは true です。
      導入:
      4.3
    • setIntegrationEvaluationContext

      public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)
    • getComponentType

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

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

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