@Configuration
public class ReactorPeerInboundChannelAdapterConfiguration<IN,OUT>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
codec |
protected java.util.Map<java.lang.String,reactor.io.codec.Codec> |
codecs |
protected java.lang.String |
dispatcher |
protected org.springframework.messaging.MessageChannel |
errorChannel |
protected java.lang.String |
framing |
protected java.lang.String |
host |
protected int |
lengthFieldLength |
protected org.springframework.messaging.MessageChannel |
outputChannel |
protected int |
port |
protected java.lang.String |
protocol |
Constructor and Description |
---|
ReactorPeerInboundChannelAdapterConfiguration() |
Modifier and Type | Method and Description |
---|---|
ReactorPeerInboundChannelAdapter<IN,OUT> |
netServerInboundChannelAdapter(reactor.io.net.ReactorPeer<IN,OUT,reactor.io.net.ChannelStream<IN,OUT>> peer) |
ReactorPeerFactoryBean<IN,OUT> |
netServerSpecFactoryBean() |
void |
setCodec(java.lang.String codec) |
void |
setCodecs(java.util.Map<java.lang.String,reactor.io.codec.Codec> codecs) |
void |
setDispatcher(java.lang.String dispatcher) |
void |
setEnv(reactor.Environment env) |
void |
setErrorChannel(org.springframework.messaging.MessageChannel errorChannel) |
void |
setFraming(java.lang.String framing) |
void |
setHost(java.lang.String host) |
void |
setLengthFieldLength(int lengthFieldLength) |
void |
setOutputChannel(org.springframework.messaging.MessageChannel outputChannel) |
void |
setPort(int port) |
void |
setProtocol(java.lang.String protocol) |
@Autowired(required=false) protected java.util.Map<java.lang.String,reactor.io.codec.Codec> codecs
@Value(value="${dispatcher:}") protected java.lang.String dispatcher
@Value(value="${protocol:tcp}") protected java.lang.String protocol
@Value(value="${host:}") protected java.lang.String host
@Value(value="${port:-1}") protected int port
@Value(value="${framing:}") protected java.lang.String framing
@Value(value="${lengthFieldLength:-1}") protected int lengthFieldLength
@Value(value="${codec:}") protected java.lang.String codec
@Autowired @Qualifier(value="output") protected org.springframework.messaging.MessageChannel outputChannel
@Autowired(required=false) @Qualifier(value="errorChannel") protected org.springframework.messaging.MessageChannel errorChannel
public ReactorPeerInboundChannelAdapterConfiguration()
@Bean public ReactorPeerFactoryBean<IN,OUT> netServerSpecFactoryBean()
@Bean public ReactorPeerInboundChannelAdapter<IN,OUT> netServerInboundChannelAdapter(reactor.io.net.ReactorPeer<IN,OUT,reactor.io.net.ChannelStream<IN,OUT>> peer)
public void setCodecs(java.util.Map<java.lang.String,reactor.io.codec.Codec> codecs)
public void setProtocol(java.lang.String protocol)
public void setDispatcher(java.lang.String dispatcher)
public void setHost(java.lang.String host)
public void setPort(int port)
public void setFraming(java.lang.String framing)
public void setLengthFieldLength(int lengthFieldLength)
public void setCodec(java.lang.String codec)
public void setOutputChannel(org.springframework.messaging.MessageChannel outputChannel)
public void setErrorChannel(org.springframework.messaging.MessageChannel errorChannel)
public void setEnv(reactor.Environment env)