ReactiveMessageSourceProducer (Spring Integration API) - Javadoc

ナビゲーションリンクをスキップ

Spring Integration

すべてのクラス

詳細:
フィールド |
コンストラクター |
メソッド

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.endpoint.AbstractEndpoint
  - - org.springframework.integration.endpoint.MessageProducerSupport
    - - org.springframework.integration.endpoint.ReactiveMessageSourceProducer

実装されているすべてのインターフェース:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, MessageProducer, IntegrationPattern, NamedComponent, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent
```
public class ReactiveMessageSourceProducer
extends MessageProducerSupport
```
提供された MessageSource を Flux に適合させ、MessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>>) でサブスクライブさせる MessageProducerSupport
導入:
5.3
作成者:
Artem Bilan

フィールドのサマリー
- クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
  lifecycleCondition, lifecycleLock
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger
- インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
  DEFAULT_PHASE

コンストラクターの概要

コンストラクター
コンストラクターと説明
`ReactiveMessageSourceProducer(MessageSource<?> messageSource)` 提供された `MessageSource` に基づいてインスタンスを作成します。

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected void`	`doStart()` デフォルトでは何もしません。
`void`	`setDelayWhenEmpty(java.time.Duration delayWhenEmpty)` `Duration` を構成して、前のリクエストが空のときに次のプルリクエストを遅らせます。

クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド
afterSingletonsInstantiated, buildErrorMessage, doStop, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName, getComponentType

- コンストラクターの詳細
  - ReactiveMessageSourceProducer
```
public ReactiveMessageSourceProducer(MessageSource<?> messageSource)
```
    提供された MessageSource に基づいてインスタンスを作成します。
    パラメーター:
    messageSource - メッセージを取得する MessageSource
- メソッドの詳細
  - setDelayWhenEmpty
```
public void setDelayWhenEmpty(java.time.Duration delayWhenEmpty)
```
    Duration を構成して、前のリクエストが空のときに次のプルリクエストを遅らせます。デフォルトは IntegrationReactiveUtils.DEFAULT_DELAY_WHEN_EMPTY です。
    パラメーター:
    delayWhenEmpty - 使用する Duration。
  - doStart
```
protected void doStart()
```
    クラスからコピーされた説明: MessageProducerSupport
    デフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。
    オーバーライド:
    クラス MessageProducerSupport の doStart

ナビゲーションリンクをスキップ

Spring Integration

すべてのクラス

詳細:
フィールド |
コンストラクター |
メソッド