クラス HazelcastContinuousQueryMessageProducer

実装されたすべてのインターフェース:
AwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanSmartInitializingSingletonApplicationContextAwareLifecyclePhasedSmartLifecycleComponentSourceAwareExpressionCapableMessageProducerIntegrationPatternNamedComponentIntegrationInboundManagementIntegrationManagementManageableLifecycleManageableSmartLifecycleTrackableComponent

public class HazelcastContinuousQueryMessageProducer extends AbstractHazelcastMessageProducer
Hazelcast Continuous Query Message Producer は、定義された述語に照らして関連する分散マップイベントをリッスンし、関連するチャネルにイベントを送信するために、SqlPredicate で AbstractHazelcastMessageProducer.HazelcastEntryListener を有効にするメッセージプロデューサーです。
導入:
6.0
作成者:
Eren Avsarogullari
  • コンストラクターの詳細

    • HazelcastContinuousQueryMessageProducer

      public HazelcastContinuousQueryMessageProducer(com.hazelcast.map.IMap distributedMap, StringSE predicate)
  • メソッドの詳細

    • setIncludeValue

      public void setIncludeValue(boolean includeValue)
    • doStart

      protected void doStart()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。
      オーバーライド:
      クラス MessageProducerSupportdoStart 
    • doStop

      protected void doStop()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。
      オーバーライド:
      クラス MessageProducerSupportdoStop 
    • getComponentType

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