public class ContinuousQueryMessageProducer extends ExpressionMessageProducerSupport implements ContinuousQueryListener
Region に対して常に評価される Gemfire 連続クエリ(#query フィールドを使用して設定)に応答します。これは、キャッシュを手動で再クエリするよりもはるかに高速です。lifecycleCondition, lifecycleLockEXPRESSION_PARSERDEFAULT_PHASE| コンストラクターと説明 |
|---|
ContinuousQueryMessageProducer(ContinuousQueryListenerContainer queryListenerContainer, StringSE query) |
| 修飾子と型 | メソッドと説明 |
|---|---|
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
void | onEvent(org.apache.geode.cache.query.CqEvent event) |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setDurable(boolean durable) |
void | setQueryName(StringSE queryName) |
void | setSupportedEventTypes(CqEventType... eventTypes) |
evaluatePayloadExpression, setIntegrationEvaluationContext, setPayloadExpression, setPayloadExpressionStringafterSingletonsInstantiated, buildErrorMessage, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherdestroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEgetBeanName, getComponentNamepublic ContinuousQueryMessageProducer(ContinuousQueryListenerContainer queryListenerContainer, StringSE query)
queryListenerContainer - ContinuousQueryListenerContainerquery - クエリ文字列 public void setQueryName(StringSE queryName)
queryName - オプションのクエリ名 public void setDurable(boolean durable)
durable - クエリが永続サブスクリプションの場合は truepublic void setSupportedEventTypes(CqEventType... eventTypes)
public StringSE getComponentType()
IntegrationObjectSupportNamedComponent の getComponentType IntegrationObjectSupport の getComponentType protected void onInit()
IntegrationObjectSupportExpressionMessageProducerSupport の onInit public void onEvent(org.apache.geode.cache.query.CqEvent event)
ContinuousQueryListener の onEvent