public class TcpOutboundGatewaySpec extends MessageHandlerSpec<TcpOutboundGatewaySpec,TcpOutboundGateway> implements ComponentsRegistration
修飾子と型 | フィールドと説明 |
---|---|
protected AbstractClientConnectionFactory | connectionFactory |
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
コンストラクターと説明 |
---|
TcpOutboundGatewaySpec(AbstractClientConnectionFactory connectionFactoryBean) 既存の spring-managed 接続ファクトリを使用してインスタンスを構築します。 |
TcpOutboundGatewaySpec(TcpClientConnectionFactorySpec connectionFactorySpec) 提供された接続ファクトリ仕様を使用してインスタンスを構成します。 |
修飾子と型 | メソッドと説明 |
---|---|
TcpOutboundGatewaySpec | async(boolean async) true に設定すると、送信スレッドが解放され、非同期で応答を受信します。 |
TcpOutboundGatewaySpec | closeStreamAfterSend(boolean closeStreamAfterSend) 接続を閉じずに送信後に接続出力ストリームを閉じるには、true に設定します。 |
MapSE<ObjectSE, StringSE> | getComponentsToRegister() |
<P> TcpOutboundGatewaySpec | remoteTimeout(java.util.function.FunctionSE<Message<P>,?> remoteTimeoutFunction) 実行時に呼び出される Function SE を構成して、メッセージの送信先を決定します。 |
TcpOutboundGatewaySpec | remoteTimeout(long remoteTimeout) |
TcpOutboundGatewaySpec | unsolictedMessageChannelName(MessageChannel channel) 迷惑メッセージチャネルを設定します。 |
TcpOutboundGatewaySpec | unsolictedMessageChannelName(StringSE channelName) 迷惑メッセージのチャネル名を設定します。 |
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
protected final AbstractClientConnectionFactory connectionFactory
public TcpOutboundGatewaySpec(AbstractClientConnectionFactory connectionFactoryBean)
connectionFactoryBean
- spring-managed Bean。public TcpOutboundGatewaySpec(TcpClientConnectionFactorySpec connectionFactorySpec)
connectionFactorySpec
- スペック。public TcpOutboundGatewaySpec remoteTimeout(long remoteTimeout)
remoteTimeout
- 設定するリモートタイムアウト。TcpOutboundGateway.setRemoteTimeout(long)
public <P> TcpOutboundGatewaySpec remoteTimeout(java.util.function.FunctionSE<Message<P>,?> remoteTimeoutFunction)
Function
SE を構成して、メッセージの送信先を決定します。通常、Java 8 ラムダ式で使用されます。
.remoteTimeout(m -> m.getHeaders().get('rto'))
P
- メッセージのペイロード型。remoteTimeoutFunction
- 関数。TcpOutboundGateway.setRemoteTimeoutExpression(org.springframework.expression.Expression)
public TcpOutboundGatewaySpec closeStreamAfterSend(boolean closeStreamAfterSend)
ByteArrayRawSerializer
を使用する場合など、サーバーに EOF を通知するために使用します。使い捨て接続ファクトリが必要です。closeStreamAfterSend
- 閉じます。public TcpOutboundGatewaySpec async(boolean async)
async
- 非同期のリクエスト / 応答の場合は true。public TcpOutboundGatewaySpec unsolictedMessageChannelName(StringSE channelName)
channelName
- 名前。public TcpOutboundGatewaySpec unsolictedMessageChannelName(MessageChannel channel)
channel
- チャンネル。public MapSE<ObjectSE,StringSE> getComponentsToRegister()
ComponentsRegistration
の getComponentsToRegister