public static class BusClient.XSocket
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BYTE_BUFFER_SIZE |
Constructor and Description |
---|
XSocket(java.lang.String name,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
connect(java.lang.String addr) |
boolean |
isConnected() |
boolean |
isReadable() |
BusClient.Multipart |
receiveMultipart() |
void |
sendMultipart(BusClient.Multipart multipart) |
boolean |
waitReadable(long timeout) |
boolean |
waitWritable(long timeout) |
void |
wakeup() |
void |
write(byte[] data,
boolean eof) |
public static final int DEFAULT_BYTE_BUFFER_SIZE
public BusClient.Multipart receiveMultipart() throws java.io.IOException
java.io.IOException
public void write(byte[] data, boolean eof) throws java.io.IOException
java.io.IOException
public void sendMultipart(BusClient.Multipart multipart) throws java.io.IOException
java.io.IOException
public void connect(java.lang.String addr) throws java.io.IOException, java.util.concurrent.TimeoutException
java.io.IOException
java.util.concurrent.TimeoutException
public boolean isConnected()
public boolean isReadable() throws java.io.IOException
java.io.IOException
public void wakeup()
public boolean waitReadable(long timeout) throws java.io.IOException
java.io.IOException
public boolean waitWritable(long timeout) throws java.io.IOException
java.io.IOException
public void close()