クラス TcpConnectionSupport
java.lang.ObjectSE
org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
- 実装されているすべてのインターフェース:
RunnableSE,TcpConnection
public abstract class TcpConnectionSupport extends ObjectSE implements TcpConnection
TcpConnections の基本クラス。TcpConnections は、クライアント接続ファクトリ(送信)またはサーバー接続ファクトリ(受信)によって確立されます。
- 導入:
- 2.0
- 作成者:
- Gary Russell, Artem Bilan
フィールドのサマリー
コンストラクターの概要
コンストラクター コンストラクター 説明 TcpConnectionSupport()TcpConnectionSupport(SocketSE socket, boolean server, boolean lookupHost, ApplicationEventPublisher applicationEventPublisher, StringSE connectionFactoryName)イベント発行者が提供されている場合は、TcpConnectionSupportオブジェクトを作成し、TcpConnectionOpenEventを発行します。TcpConnectionSupport(ApplicationEventPublisher applicationEventPublisher)メソッドのサマリー
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース org.springframework.integration.ip.tcp.connection.TcpConnection から継承されたメソッド
getDeserializerStateKey, getPayload, getPort, getSslSession, isOpen, send, shutdownInput, shutdownOutput
フィールドの詳細
コンストラクターの詳細
TcpConnectionSupport
public TcpConnectionSupport()TcpConnectionSupport
TcpConnectionSupport
public TcpConnectionSupport(SocketSE socket, boolean server, boolean lookupHost, @Nullable ApplicationEventPublisher applicationEventPublisher, @Nullable StringSE connectionFactoryName)イベント発行者が提供されている場合は、TcpConnectionSupportオブジェクトを作成し、TcpConnectionOpenEventを発行します。- パラメーター:
socket- 基本となるソケット。server- この接続がサーバー接続の場合は truelookupHost- ホスト名の逆ルックアップを実行する必要がある場合は true、それ以外の場合は、識別のために IP アドレスが使用されます。applicationEventPublisher- オープン、クローズ、例外イベントが送信されるパブリッシャー。イベントの公開が不要な場合は null になることがあります。connectionFactoryName- この接続を作成する接続ファクトリの名前。イベントの発行中に使用され、null の場合があります。その場合、「不明」が使用されます。
メソッドの詳細
close
public void close()この接続を閉じます。- 次で指定:
- インターフェース
TcpConnectionのclose
closeConnection
protected void closeConnection(boolean isException)インターセプトされている場合は、最も外側のインターセプターからクローズを伝搬します。それ以外の場合は、close() を呼び出します。- パラメーター:
isException- この呼び出しが例外の結果である場合は true。
getMapper
- 戻り値:
- マッパー
setMapper
- パラメーター:
mapper- 設定するマッパー
getDeserializer
- 次で指定:
- インターフェース
TcpConnectionのgetDeserializer - 戻り値:
- デシリアライザー
setDeserializer
- パラメーター:
deserializer- 設定するデシリアライザー
getSerializer
- 次で指定:
- インターフェース
TcpConnectionのgetSerializer - 戻り値:
- シリアライザー
setSerializer
- パラメーター:
serializer- 設定するシリアライザー
setNeedsTest
public void setNeedsTest(boolean needsTest)最初の受信メッセージのみに一時リスナーを使用するには、true に設定します。- パラメーター:
needsTest- 一時リスナーの場合は true。- 導入:
- 5.3
registerListener
受信メッセージを受信するリスナーを設定します。- パラメーター:
listener- リスナー。
registerTestListener
最初の受信メッセージのみを受信するように一時リスナーを設定します。クライアント接続ファクトリの connectionTest と組み合わせて使用します。- パラメーター:
tListener- テストリスナー。- 導入:
- 5.3
enableManualListenerRegistration
public void enableManualListenerRegistration()TcpListenerの自動登録または手動登録を使用するかどうかを設定します。(デフォルトは自動)。手動登録が行われている場合、受信メッセージはリスナーが登録されるまで遅延されます。- 導入:
- 1.4.5
registerSender
送信者を登録します。送信者が応答を送信する接続を決定できるように、サーバー側の接続で使用されます。- パラメーター:
senderToRegister- 送り主。
registerSenders
送信者を登録します。送信者が応答を送信する接続を決定できるように、サーバー側の接続で使用されます。- パラメーター:
sendersToRegister- 送り主。- 導入:
- 5.4
getListener
- 次で指定:
- インターフェース
TcpConnectionのgetListener - 戻り値:
- リスナー
getSender
- 戻り値:
- 存在する場合、最初の送信者。
getSenders
送信者のリストを返します。- 戻り値:
- 送信者。
- 導入:
- 5.4
isServer
public boolean isServer()- 次で指定:
- インターフェース
TcpConnectionのisServer - 戻り値:
- 接続が 1 回使用される場合は true。
incrementAndGetConnectionSequence
public long incrementAndGetConnectionSequence()- 次で指定:
- インターフェース
TcpConnectionのincrementAndGetConnectionSequence - 戻り値:
- このソケットで受信したメッセージの次のシーケンス番号
getHostAddress
- 次で指定:
- インターフェース
TcpConnectionのgetHostAddress - 戻り値:
- ホストアドレス
getHostName
- 次で指定:
- インターフェース
TcpConnectionのgetHostName - 戻り値:
- ホスト名
getConnectionId
- 次で指定:
- インターフェース
TcpConnectionのgetConnectionId - 戻り値:
- 接続を一意に表す文字列。
getSocketInfo
インターフェースからコピーされた説明:TcpConnectionSocketSE プロパティに getter を提供します。- 次で指定:
- インターフェース
TcpConnectionのgetSocketInfo - 戻り値:
- socketInfo - たとえばインターセプターでは null になる場合があります。インターセプターはオーバーライドして実際の TcpConnection に委譲する必要があります。
- 導入:
- 4.2.5
setWrapped
public void setWrapped(boolean wrapped)インターセプトされた場合は true に設定します。- パラメーター:
wrapped- ラップされている場合は true。- 導入:
- 5.4.5
setWrapper
ラッパーを設定します。- パラメーター:
wrapper- ラッパー。- 導入:
- 5.4.6
getConnectionFactoryName
isNoReadErrorOnClose
protected boolean isNoReadErrorOnClose()setNoReadErrorOnClose
protected void setNoReadErrorOnClose(boolean noReadErrorOnClose)sendExceptionToListener
publishConnectionOpenEvent
protected void publishConnectionOpenEvent()publishConnectionCloseEvent
protected void publishConnectionCloseEvent()publishConnectionExceptionEvent
publishEvent
インターセプターなどがイベント、おそらく TcpConnectionEvent のサブクラスを発行できるようにします。イベントソースはこの接続である必要があります。- パラメーター:
event- 公開するイベント。
toString