FluxMessageChannel (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.channel.AbstractMessageChannel
  - - org.springframework.integration.channel.FluxMessageChannel

実装されているすべてのインターフェース:
org.reactivestreams.Publisher<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ReactiveStreamsSubscribableChannel, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageChannel, InterceptableChannel
```
public class FluxMessageChannel
extends AbstractMessageChannel
implements org.reactivestreams.Publisher<Message<?>>, ReactiveStreamsSubscribableChannel
```
プロジェクト Reactor Flux に基づく Reactive Streams Publisher の AbstractMessageChannel 実装。
導入:
5.0
作成者:
Artem Bilan, Gary Russell, Sergei Egorov

ネストされたクラスの要約
- クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたネストクラス / インターフェース
  AbstractMessageChannel.ChannelInterceptorList
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
  IntegrationManagement.ManagementOverrides

フィールドのサマリー
- クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたフィールド
  interceptors, meters
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger
- インターフェース org.springframework.messaging.MessageChannel から継承されたフィールド
  INDEFINITE_TIMEOUT
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
  METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

コンストラクターの概要
コンストラクター
コンストラクターと説明
FluxMessageChannel()

コンストラクター
コンストラクターと説明
`FluxMessageChannel()`

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`void`	`destroy()`
`protected boolean`	`doSend(Message<?> message, long timeout)` サブクラスはこのメソッドを実装する必要があります。
`void`	`subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)`
`void`	`subscribeTo(org.reactivestreams.Publisher<? extends Message<?>> publisher)`

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたメソッド
addInterceptor, addInterceptor, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, onInit, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrack

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, 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, toString

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

インターフェース org.springframework.integration.channel.ReactiveStreamsSubscribableChannel から継承されたメソッド
getIntegrationPatternType

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getManagedName, getManagedType, getThisAs, setManagedName, setManagedType

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

- コンストラクターの詳細
  - FluxMessageChannel
```
public FluxMessageChannel()
```
- メソッドの詳細
  - doSend
```
protected boolean doSend(Message<?> message,
                         long timeout)
```
    クラスからコピーされた説明: AbstractMessageChannel
    サブクラスはこのメソッドを実装する必要があります。負でないタイムアウトは、チャネルが容量に達した場合に待機する時間を示します（値が 0 の場合、成功の有無にかかわらずすぐに戻る必要があります）。負のタイムアウト値は、メッセージが受け入れられるか、ブロッキングスレッドが中断されるまでメソッドがブロックされることを示します。
    次で指定:
    クラス AbstractMessageChannel の doSend
    パラメーター:
    message - メッセージ。
    timeout - タイムアウト。
    戻り値:
    送信が成功した場合は true。
  - subscribe
```
public void subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)
```
    次で指定:
    インターフェース org.reactivestreams.Publisher<Message<?>> の subscribe
  - subscribeTo
```
public void subscribeTo(org.reactivestreams.Publisher<? extends Message<?>> publisher)
```
    次で指定:
    インターフェース ReactiveStreamsSubscribableChannel の subscribeTo
  - destroy
```
public void destroy()
```
    次で指定:
    インターフェース DisposableBean の destroy
    次で指定:
    インターフェース IntegrationManagement の destroy
    オーバーライド:
    クラス AbstractMessageChannel の destroy

クラス FluxMessageChannel

ネストされたクラスの要約

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたネストクラス / インターフェース

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.messaging.MessageChannel から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.integration.channel.ReactiveStreamsSubscribableChannel から継承されたメソッド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド

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

コンストラクターの詳細

FluxMessageChannel

メソッドの詳細

doSend

subscribe

subscribeTo

destroy