public class TcpOutboundGatewaySpec extends MessageHandlerSpec<TcpOutboundGatewaySpec,TcpOutboundGateway> implements ComponentsRegistration
MessageHandlerSpec
for TcpOutboundGateway
s.logger, PARSER, target
Constructor and Description |
---|
TcpOutboundGatewaySpec(AbstractClientConnectionFactory connectionFactoryBean)
Construct an instance using an existing spring-managed connection factory.
|
TcpOutboundGatewaySpec(TcpClientConnectionFactorySpec connectionFactorySpec)
Construct an instance using the supplied connection factory spec.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.Object,java.lang.String> |
getComponentsToRegister() |
<P> TcpOutboundGatewaySpec |
remoteTimeout(java.util.function.Function<org.springframework.messaging.Message<P>,?> remoteTimeoutFunction)
Configure a
Function that will be invoked at runtime to determine the destination to
which a message will be sent. |
TcpOutboundGatewaySpec |
remoteTimeout(long remoteTimeout) |
_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, id
public TcpOutboundGatewaySpec(AbstractClientConnectionFactory connectionFactoryBean)
connectionFactoryBean
- the spring-managed bean.public TcpOutboundGatewaySpec(TcpClientConnectionFactorySpec connectionFactorySpec)
connectionFactorySpec
- the spec.public TcpOutboundGatewaySpec remoteTimeout(long remoteTimeout)
remoteTimeout
- the remote timeout to set.TcpOutboundGateway.setRemoteTimeout(long)
public <P> TcpOutboundGatewaySpec remoteTimeout(java.util.function.Function<org.springframework.messaging.Message<P>,?> remoteTimeoutFunction)
Function
that will be invoked at runtime to determine the destination to
which a message will be sent. Typically used with a Java 8 Lambda expression:
.remoteTimeout(m -> m.getHeaders().get('rto'))
P
- the message payload type.remoteTimeoutFunction
- the function.TcpOutboundGateway.setRemoteTimeoutExpression(org.springframework.expression.Expression)
public java.util.Map<java.lang.Object,java.lang.String> getComponentsToRegister()
getComponentsToRegister
in interface ComponentsRegistration