TcpSendingMessageHandler (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.handler.MessageHandlerSupport
  - - org.springframework.integration.handler.AbstractMessageHandler
    - - org.springframework.integration.ip.tcp.TcpSendingMessageHandler

実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Ordered, ExpressionCapable, Orderable, IntegrationPattern, ClientModeCapable, TcpSender, NamedComponent, IntegrationManagement, ManageableLifecycle, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
```
public class TcpSendingMessageHandler
extends AbstractMessageHandler
implements TcpSender, ManageableLifecycle, ClientModeCapable
```
TcpConnection を使用してデータを送信する Tcp 送信チャネルアダプター - 接続ファクトリがサーバーファクトリである場合、TcpListener が接続を所有します。クライアントファクトリの場合、このオブジェクトが接続を所有します。
導入:
2.0
作成者:
Gary Russell, Artem Bilan

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

フィールドのサマリー

フィールド
修飾子と型	フィールドと説明
`static long`	`DEFAULT_RETRY_INTERVAL` `ClientModeConnectionManager` 再スケジュールのデフォルトの再試行間隔。
`protected ObjectSE`	`lifecycleMonitor`

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

インターフェース org.springframework.core.Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

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

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

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

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`void`	`addNewConnection(TcpConnection connection)` `TcpListener` が所有するソケットを使用している場合、このメソッドは新しい接続が確立されるたびに呼び出されます。
`protected TcpConnection`	`doWrite(Message<?> message)` 実際に書き込みを行うメソッド。
`protected ConnectionFactory`	`getClientConnectionFactory()`
`StringSE`	`getComponentType()` サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
`protected MapSE<StringSE, TcpConnection>`	`getConnections()`
`long`	`getRetryInterval()`
`protected ConnectionFactory`	`getServerConnectionFactory()`
`void`	`handleMessageInternal(Message<?> message)` 指定されたメッセージ形式を使用して、基になるソケットにメッセージペイロードを書き込みます。
`boolean`	`isClientMode()`
`boolean`	`isClientModeConnected()`
`boolean`	`isRunning()`
`protected TcpConnection`	`obtainConnection(Message<?> message)`
`protected void`	`onInit()` サブクラスは、初期化ロジック用にこれを実装できます。
`void`	`removeDeadConnection(TcpConnection connection)` `TcpListener` が所有するソケットを使用している場合、このメソッドは接続が閉じられるたびに呼び出されます。
`void`	`retryConnection()` すぐに接続の確立を試みてください。
`void`	`setClientMode(boolean isClientMode)`
`void`	`setConnectionFactory(AbstractConnectionFactory connectionFactory)` クライアントまたはサーバー接続ファクトリを設定します。この場合（送信アダプター）、ファクトリがサーバー接続ファクトリである場合、ソケットは受信チャネルアダプターによって所有され、このアダプターは応答の送信に使用されます。
`void`	`setRetryInterval(long retryInterval)`
`void`	`start()`
`void`	`stop()`

クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド
handleMessage, onComplete, onError, onNext, onSubscribe

クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

クラス 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

インターフェース reactor.core.CoreSubscriber から継承されたメソッド
currentContext

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

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

- フィールドの詳細
  - DEFAULT_RETRY_INTERVAL
```
public static final long DEFAULT_RETRY_INTERVAL
```
    ClientModeConnectionManager 再スケジュールのデフォルトの再試行間隔。
    関連事項:
    定数フィールド値
  - lifecycleMonitor
```
protected final ObjectSE lifecycleMonitor
```
- コンストラクターの詳細
  - TcpSendingMessageHandler
```
public TcpSendingMessageHandler()
```
- メソッドの詳細
  - obtainConnection
```
protected TcpConnection obtainConnection(Message<?> message)
```
  - handleMessageInternal
```
public void handleMessageInternal(Message<?> message)
```
    指定されたメッセージ形式を使用して、基になるソケットにメッセージペイロードを書き込みます。
    次で指定:
    クラス AbstractMessageHandler の handleMessageInternal
    関連事項:
    MessageHandler.handleMessage(org.springframework.messaging.Message)
  - doWrite
```
protected TcpConnection doWrite(Message<?> message)
```
    実際に書き込みを行うメソッド。
    パラメーター:
    message - 書くメッセージ。
    戻り値:
    接続。
  - setConnectionFactory
```
public void setConnectionFactory(AbstractConnectionFactory connectionFactory)
```
    クライアントまたはサーバー接続ファクトリを設定します。この場合（送信アダプター）、ファクトリがサーバー接続ファクトリである場合、ソケットは受信チャネルアダプターによって所有され、このアダプターは応答の送信に使用されます。
    パラメーター:
    connectionFactory - 設定する connectionFactory
  - addNewConnection
```
public void addNewConnection(TcpConnection connection)
```
    インターフェースからコピーされた説明: TcpSender
    TcpListener が所有するソケットを使用している場合、このメソッドは新しい接続が確立されるたびに呼び出されます。
    次で指定:
    インターフェース TcpSender の addNewConnection
    パラメーター:
    connection - 接続。
  - removeDeadConnection
```
public void removeDeadConnection(TcpConnection connection)
```
    インターフェースからコピーされた説明: TcpSender
    TcpListener が所有するソケットを使用している場合、このメソッドは接続が閉じられるたびに呼び出されます。
    次で指定:
    インターフェース TcpSender の removeDeadConnection
    パラメーター:
    connection - 接続。
  - getComponentType
```
public StringSE getComponentType()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
    次で指定:
    インターフェース NamedComponent の getComponentType
    オーバーライド:
    クラス MessageHandlerSupport の getComponentType
  - onInit
```
protected void onInit()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスは、初期化ロジック用にこれを実装できます。
    オーバーライド:
    クラス IntegrationObjectSupport の onInit
  - start
```
public void start()
```
    次で指定:
    インターフェース Lifecycle の start
    次で指定:
    インターフェース ManageableLifecycle の start
  - stop
```
public void stop()
```
    次で指定:
    インターフェース Lifecycle の stop
    次で指定:
    インターフェース ManageableLifecycle の stop
  - isRunning
```
public boolean isRunning()
```
    次で指定:
    インターフェース Lifecycle の isRunning
    次で指定:
    インターフェース ManageableLifecycle の isRunning
  - getClientConnectionFactory
```
protected ConnectionFactory getClientConnectionFactory()
```
    戻り値:
    clientConnectionFactory
  - getServerConnectionFactory
```
protected ConnectionFactory getServerConnectionFactory()
```
    戻り値:
    serverConnectionFactory
  - getConnections
```
protected MapSE<StringSE,TcpConnection> getConnections()
```
    戻り値:
    接続
  - isClientMode
```
public boolean isClientMode()
```
    次で指定:
    インターフェース ClientModeCapable の isClientMode
    戻り値:
    isClientMode
  - setClientMode
```
public void setClientMode(boolean isClientMode)
```
    パラメーター:
    isClientMode - 設定する isClientMode
  - getRetryInterval
```
public long getRetryInterval()
```
    戻り値:
    retryInterval
  - setRetryInterval
```
public void setRetryInterval(long retryInterval)
```
    パラメーター:
    retryInterval - 設定する retryInterval
  - isClientModeConnected
```
public boolean isClientModeConnected()
```
    次で指定:
    インターフェース ClientModeCapable の isClientModeConnected
    戻り値:
    エンドポイントがクライアントモードで実行されている場合は true。
  - retryConnection
```
public void retryConnection()
```
    インターフェースからコピーされた説明: ClientModeCapable
    すぐに接続の確立を試みてください。
    次で指定:
    インターフェース ClientModeCapable の retryConnection

クラス TcpSendingMessageHandler

ネストされたクラスのサマリー

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

フィールドのサマリー

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

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

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

コンストラクターの概要

メソッドのサマリー

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

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

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

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

インターフェース reactor.core.CoreSubscriber から継承されたメソッド

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

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

フィールドの詳細

DEFAULT_RETRY_INTERVAL

lifecycleMonitor

コンストラクターの詳細

TcpSendingMessageHandler

メソッドの詳細

obtainConnection

handleMessageInternal

doWrite

setConnectionFactory

addNewConnection

removeDeadConnection

getComponentType

onInit

start

stop

isRunning

getClientConnectionFactory

getServerConnectionFactory

getConnections

isClientMode

setClientMode

getRetryInterval

setRetryInterval

isClientModeConnected

retryConnection