クラス HazelcastContinuousQueryMessageProducer
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer
org.springframework.integration.hazelcast.inbound.HazelcastContinuousQueryMessageProducer
- 実装されたすべてのインターフェース:
Aware
、BeanFactoryAware
、BeanNameAware
、DisposableBean
、InitializingBean
、SmartInitializingSingleton
、ApplicationContextAware
、Lifecycle
、Phased
、SmartLifecycle
、ComponentSourceAware
、ExpressionCapable
、MessageProducer
、IntegrationPattern
、NamedComponent
、IntegrationInboundManagement
、IntegrationManagement
、ManageableLifecycle
、ManageableSmartLifecycle
、TrackableComponent
Hazelcast Continuous Query Message Producer は、定義された述語に照らして関連する分散マップイベントをリッスンし、関連するチャネルにイベントを送信するために、
SqlPredicate
で AbstractHazelcastMessageProducer.HazelcastEntryListener
を有効にするメッセージプロデューサーです。- 導入:
- 6.0
- 作成者:
- Eren Avsarogullari
ネストされたクラスのサマリー
クラス org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer から継承されたネストクラス / インターフェース
AbstractHazelcastMessageProducer.AbstractHazelcastEventListener<E>, AbstractHazelcastMessageProducer.HazelcastEntryListener<K,
V> インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドのサマリー
クラス org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer から継承されたフィールド
distributedObject
クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
lifecycleCondition, lifecycleLock
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターの概要
コンストラクターコンストラクター説明HazelcastContinuousQueryMessageProducer
(com.hazelcast.map.IMap distributedMap, StringSE predicate) メソッドのサマリー
修飾子と型メソッド説明protected void
doStart()
デフォルトでは何もしません。protected void
doStop()
デフォルトでは何もしません。サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。void
setIncludeValue
(boolean includeValue) クラス org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer から継承されたメソッド
getCacheEvents, getCacheListeningPolicy, getHazelcastRegisteredEventListenerId, setCacheEventTypes, setCacheListeningPolicy, setHazelcastRegisteredEventListenerId
クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, isObserved, onInit, registerObservationRegistry, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setObservationConvention, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher
クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
destroy, getManagedName, getManagedType, getOverrides, getThisAs, isLoggingEnabled, registerMetricsCaptor, setLoggingEnabled, setManagedName, setManagedType
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName
コンストラクターの詳細
HazelcastContinuousQueryMessageProducer
public HazelcastContinuousQueryMessageProducer(com.hazelcast.map.IMap distributedMap, StringSE predicate)
メソッドの詳細
setIncludeValue
public void setIncludeValue(boolean includeValue) doStart
protected void doStart()クラスからコピーされた説明:MessageProducerSupport
デフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。- オーバーライド:
- クラス
MessageProducerSupport
のdoStart
doStop
protected void doStop()クラスからコピーされた説明:MessageProducerSupport
デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。- オーバーライド:
- クラス
MessageProducerSupport
のdoStop
getComponentType
クラスからコピーされた説明:IntegrationObjectSupport
サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。- 次で指定:
- インターフェース
NamedComponent
のgetComponentType
- オーバーライド:
- クラス
IntegrationObjectSupport
のgetComponentType