com.crankuptheamps.client
Interface Transport

All Known Implementing Classes:
TCPTransport

public interface Transport


Method Summary
 Message allocateMessage()
           
 void close()
           
 void connect(URI uri)
           
 void disconnect()
           
 long flush()
           
 long flush(long timeout)
           
 int getVersion()
           
 void handleCloseEvent(int failedVersion_, String message, Exception e)
           
 long readQueueSize()
           
 void send(Message message)
           
 void sendWithoutRetry(Message message)
           
 void setDisconnectHandler(TransportDisconnectHandler dh)
           
 void setExceptionListener(ExceptionListener exceptionListener)
           
 void setMessageHandler(MessageHandler ml)
           
 void setReadTimeout(int readTimeoutMillis_)
           
 void setTransportFilter(TransportFilter filter_)
          Sets a TransportFilter that filters raw bytes before send and after receive.
 long writeQueueSize()
           
 

Method Detail

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.