Modifier and Type | Field and Description |
---|---|
static long |
TIME_OUT |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
equals(Object client) |
org.jboss.netty.bootstrap.ClientBootstrap |
getBootstrap() |
org.jboss.netty.channel.ChannelUpstreamHandler |
getClientHandler() |
org.jboss.netty.channel.ChannelFuture |
getFuture() |
String |
getHost() |
int |
getPort() |
Response |
invoke(Request request) |
boolean |
isConnected() |
Client |
reconnect() |
void |
sendMessage(Request request) |
Response |
sendRequest(Request request) |
void |
shutdown() |
static TCPClient |
start(String host,
int port) |
static TCPClient |
start(String host,
int port,
org.jboss.netty.channel.ChannelUpstreamHandler clientHandler)
Use nonSharableChannelPipeline which create a decoder for each connection
|
static TCPClient |
start(String host,
int port,
org.jboss.netty.channel.ChannelUpstreamHandler clientHandler,
byte version) |
static TCPClient |
start(String host,
int port,
org.jboss.netty.channel.ChannelUpstreamHandler clientHandler,
org.jboss.netty.channel.ChannelDownstreamHandler encoder,
org.jboss.netty.handler.codec.frame.FrameDecoder decoder) |
static TCPClient |
startOio(String host,
int port,
org.jboss.netty.channel.ChannelUpstreamHandler clientHandler)
Use nonSharableChannelPipeline which create a decoder for each connection
|
static TCPClient |
startOio(String host,
int port,
org.jboss.netty.channel.ChannelUpstreamHandler clientHandler,
org.jboss.netty.channel.ChannelDownstreamHandler encoder,
org.jboss.netty.handler.codec.frame.FrameDecoder decoder) |
String |
toString() |
public static final long TIME_OUT
public String getHost()
public int getPort()
public org.jboss.netty.channel.ChannelFuture getFuture()
public org.jboss.netty.bootstrap.ClientBootstrap getBootstrap()
public static TCPClient start(String host, int port, org.jboss.netty.channel.ChannelUpstreamHandler clientHandler, org.jboss.netty.channel.ChannelDownstreamHandler encoder, org.jboss.netty.handler.codec.frame.FrameDecoder decoder)
host
- port
- clientHandler
- encoder
- decoder
- must be thread safepublic static TCPClient start(String host, int port, org.jboss.netty.channel.ChannelUpstreamHandler clientHandler)
host
- port
- clientHandler
- public static TCPClient startOio(String host, int port, org.jboss.netty.channel.ChannelUpstreamHandler clientHandler)
host
- port
- clientHandler
- public static TCPClient startOio(String host, int port, org.jboss.netty.channel.ChannelUpstreamHandler clientHandler, org.jboss.netty.channel.ChannelDownstreamHandler encoder, org.jboss.netty.handler.codec.frame.FrameDecoder decoder)
host
- port
- clientHandler
- encoder
- decoder
- must be thread safepublic static TCPClient start(String host, int port, org.jboss.netty.channel.ChannelUpstreamHandler clientHandler, byte version)
public boolean isConnected()
isConnected
in interface Client
public org.jboss.netty.channel.ChannelUpstreamHandler getClientHandler()
public Response sendRequest(Request request)
sendRequest
in interface Client
public void sendMessage(Request request)
sendMessage
in interface Client
Copyright © 2016. All rights reserved.