com.crankuptheamps.client
Interface Transport
- All Known Implementing Classes:
- TCPTransport
public interface Transport
connect
void connect(URI uri)
throws ConnectionRefusedException,
AlreadyConnectedException,
InvalidURIException
- Throws:
ConnectionRefusedException
AlreadyConnectedException
InvalidURIException
close
void close()
disconnect
void disconnect()
setMessageHandler
void setMessageHandler(MessageHandler ml)
setDisconnectHandler
void setDisconnectHandler(TransportDisconnectHandler dh)
setExceptionListener
void setExceptionListener(ExceptionListener exceptionListener)
send
void send(Message message)
throws DisconnectedException
- Throws:
DisconnectedException
sendWithoutRetry
void sendWithoutRetry(Message message)
throws DisconnectedException
- Throws:
DisconnectedException
allocateMessage
Message allocateMessage()
writeQueueSize
long writeQueueSize()
throws DisconnectedException
- Throws:
DisconnectedException
readQueueSize
long readQueueSize()
throws DisconnectedException
- Throws:
DisconnectedException
flush
long flush()
throws DisconnectedException
- Throws:
DisconnectedException
flush
long flush(long timeout)
throws DisconnectedException
- Throws:
DisconnectedException
handleCloseEvent
void handleCloseEvent(int failedVersion_,
String message,
Exception e)
throws DisconnectedException,
RetryOperationException
- Throws:
DisconnectedException
RetryOperationException
getVersion
int getVersion()
setReadTimeout
void setReadTimeout(int readTimeoutMillis_)
setTransportFilter
void setTransportFilter(TransportFilter filter_)
- Sets a TransportFilter that filters raw bytes before send and after receive.
- Parameters:
filter_
- A TransportFilter instance such as com.crankuptheamps.client.TransportTraceFilter.