クラス 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
、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 から継承されたフィールド
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
コンストラクターのサマリー
コンストラクターコンストラクター説明MongoDbChangeStreamMessageProducer
(ReactiveMongoOperations mongoOperations) 提供されたReactiveMongoOperations
に基づいてインスタンスを作成します。メソッドのサマリー
修飾子と型メソッド説明protected void
doStart()
デフォルトでは何もしません。サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。void
setCollection
(StringSE collection) 変更イベントを追跡するコレクション名を指定します。void
setDomainType
(ClassSE<?> domainType) イベント本体を変換するオブジェクト型を指定します。void
setExtractBody
(boolean extractBody) このチャネルアダプターを構成して、ChangeStreamEvent.getBody()
(デフォルト)に基づくペイロードで生成するMessage
を構築するか、ChangeStreamEvent
全体をペイロードとして使用します。void
setOptions
(ChangeStreamOptions options) ChangeStreamOptions
を指定します。クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド
afterSingletonsInstantiated, buildErrorMessage, doStop, 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, getComponentName, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, 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
コンストラクターの詳細
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
クラスからコピーされた説明:IntegrationObjectSupport
サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。- 次で指定:
- インターフェース
NamedComponent
のgetComponentType
- オーバーライド:
- クラス
IntegrationObjectSupport
のgetComponentType
doStart
protected void doStart()クラスからコピーされた説明:MessageProducerSupport
デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。"lifecycleLock" によって保護されています。- オーバーライド:
- クラス
MessageProducerSupport
のdoStart