クラス MongoDbChangeStreamMessageProducer
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.mongodb.inbound.MongoDbChangeStreamMessageProducer
- 実装済みのインターフェース一覧:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ComponentSourceAware、ExpressionCapable、MessageProducer、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent
MongoDB 変更ストリーム実装用の
MessageProducerSupport。この機能は、ReactiveMongoOperations.changeStream(String, ChangeStreamOptions, Class) および MessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher) の消費量に基づいています。- 導入:
- 5.3
- 作成者:
- Artem Bilan
ネストされたクラスの概要
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールド概要
クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
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コンストラクター概要
コンストラクターコンストラクター説明MongoDbChangeStreamMessageProducer(ReactiveMongoOperations mongoOperations) 提供されたReactiveMongoOperationsに基づいてインスタンスを作成します。方法の概要
修飾子と型メソッド説明protected voiddoStart()デフォルトでは何もしません。voidsetCollection(StringSE collection) 変更イベントを追跡するコレクション名を指定します。voidsetDomainType(ClassSE<?> domainType) イベント本体を変換するオブジェクト型を指定します。voidsetExtractBody(boolean extractBody) このチャネルアダプターを構成して、ChangeStreamEvent.getBody()（デフォルト）に基づくペイロードで生成するMessageを構築するか、ChangeStreamEvent全体をペイロードとして使用します。voidsetOptions(ChangeStreamOptions options) ChangeStreamOptionsを指定します。クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド
afterSingletonsInstantiated, buildErrorMessage, doStop, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, getRequiredOutputChannel, 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インターフェース org.springframework.context.SmartLifecycle から継承されたメソッド
isPauseable
コンストラクターの詳細
MongoDbChangeStreamMessageProducer
提供されたReactiveMongoOperationsに基づいてインスタンスを作成します。- パラメーター:
mongoOperations- 使用するReactiveMongoOperations。- 関連事項:
メソッドの詳細
setDomainType
イベント本体を変換するオブジェクト型を指定します。デフォルトはDocumentクラスです。- パラメーター:
domainType- イベント本体変換のクラス。- 関連事項:
setCollection
変更イベントを追跡するコレクション名を指定します。デフォルトでは、mongoOperationsで構成されたデータベース内のすべてのコレクションを追跡します。- パラメーター:
collection- 使用するコレクション。- 関連事項:
setOptions
ChangeStreamOptionsを指定します。- パラメーター:
options- 使用するChangeStreamOptions。- 関連事項:
setExtractBody
public void setExtractBody(boolean extractBody) このチャネルアダプターを構成して、ChangeStreamEvent.getBody()（デフォルト）に基づくペイロードで生成するMessageを構築するか、ChangeStreamEvent全体をペイロードとして使用します。- パラメーター:
extractBody-ChangeStreamEvent.getBody()を抽出するかどうか。
getComponentType
- 次で指定:
- インターフェース
NamedComponentのgetComponentType - オーバーライド:
- クラス
MessageProducerSupportのgetComponentType
doStart
protected void doStart()クラスからコピーされた説明:MessageProducerSupportデフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。- オーバーライド:
- クラス
MessageProducerSupportのdoStart