com.crankuptheamps.client

Class Client.ClientHandler.TransportConnectionMeasurer

java.lang.Object

com.crankuptheamps.client.Client.ClientHandler.TransportConnectionMeasurer

All Implemented Interfaces:

Transport, java.lang.AutoCloseable

Enclosing class:

Client.ClientHandler

public class Client.ClientHandler.TransportConnectionMeasurer
extends java.lang.Object
implements Transport

Constructor Summary

Constructors

Constructor and Description
TransportConnectionMeasurer(Transport underlying)

Method Summary

Modifier and Type	Method and Description
Message	allocateMessage()
void	clear()
void	close()
void	connect(java.net.URI uri) Connect to an AMPS server.
void	disconnect()
long	flush()
long	flush(long timeout)
AMPSRunnable	getIdleRunnable() Gets the AMPSRunnable that is invoked during idle-time processing for this connection.
int	getVersion()
void	handleCloseEvent(int failedVersion_, java.lang.String message, java.lang.Exception e)
void	initFromClient(Client client) Called by Client before calling connect to give Transport access to any information in the Client needed by the Transport such as message handler, exceptionListener, etc.
long	readQueueSize()
void	send(Message message)
void	sendWithoutRetry(Message message)
void	sendWithoutRetry(Message message, boolean isBatch)
void	setBatchSend(int batchSendBytes, int timeoutMillis, boolean clear)
void	setDisconnectHandler(TransportDisconnectHandler dh)
void	setExceptionListener(java.beans.ExceptionListener exceptionListener)
void	setIdleRunnable(AMPSRunnable runnable) Sets a AMPSRunnable that is invoked during idle-time processing for this connection.
void	setMessageHandler(MessageHandler ml)
void	setReadTimeout(int readTimeoutMillis_)
void	setThreadCreatedHandler(ThreadCreatedHandler tch_)
void	setTransportFilter(TransportFilter tracer_) Sets a TransportFilter that filters raw bytes before send and after receive.
boolean	successfullyConnected()
long	writeQueueSize()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransportConnectionMeasurer

public TransportConnectionMeasurer(Transport underlying)

Method Detail

clear

public void clear()

successfullyConnected

public boolean successfullyConnected()

connect

public void connect(java.net.URI uri)
             throws ConnectionRefusedException,
                    AlreadyConnectedException,
                    InvalidURIException

Description copied from interface: Transport

Connect to an AMPS server.

Specified by:

connect in interface Transport

Parameters:

uri - Specifies the protocol and address of the server.

Throws:

ConnectionRefusedException - The connection was refused by the server.

AlreadyConnectedException - The transport is already connected to a server.

InvalidURIException - The URI is invalid.

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

disconnect

public void disconnect()

Specified by:

disconnect in interface Transport

setMessageHandler

public void setMessageHandler(MessageHandler ml)

Specified by:

setMessageHandler in interface Transport

setDisconnectHandler

public void setDisconnectHandler(TransportDisconnectHandler dh)

Specified by:

setDisconnectHandler in interface Transport

setExceptionListener

public void setExceptionListener(java.beans.ExceptionListener exceptionListener)

Specified by:

setExceptionListener in interface Transport

setThreadCreatedHandler

public void setThreadCreatedHandler(ThreadCreatedHandler tch_)

Specified by:

setThreadCreatedHandler in interface Transport

send

public void send(Message message)
          throws DisconnectedException

Specified by:

send in interface Transport

Throws:

DisconnectedException

sendWithoutRetry

public void sendWithoutRetry(Message message)
                      throws DisconnectedException

Specified by:

sendWithoutRetry in interface Transport

Throws:

DisconnectedException

sendWithoutRetry

public void sendWithoutRetry(Message message,
                             boolean isBatch)
                      throws DisconnectedException

Throws:

DisconnectedException

allocateMessage

public Message allocateMessage()

Specified by:

allocateMessage in interface Transport

writeQueueSize

public long writeQueueSize()
                    throws DisconnectedException

Specified by:

writeQueueSize in interface Transport

Throws:

DisconnectedException

readQueueSize

public long readQueueSize()
                   throws DisconnectedException

Specified by:

readQueueSize in interface Transport

Throws:

DisconnectedException

flush

public long flush()
           throws DisconnectedException

Specified by:

flush in interface Transport

Throws:

DisconnectedException

flush

public long flush(long timeout)
           throws DisconnectedException

Specified by:

flush in interface Transport

Throws:

DisconnectedException

handleCloseEvent

public void handleCloseEvent(int failedVersion_,
                             java.lang.String message,
                             java.lang.Exception e)
                      throws DisconnectedException,
                             RetryOperationException

Specified by:

handleCloseEvent in interface Transport

Throws:

DisconnectedException

RetryOperationException

getVersion

public int getVersion()

Specified by:

getVersion in interface Transport

setReadTimeout

public void setReadTimeout(int readTimeoutMillis_)

Specified by:

setReadTimeout in interface Transport

setTransportFilter

public void setTransportFilter(TransportFilter tracer_)

Description copied from interface: Transport

Sets a TransportFilter that filters raw bytes before send and after receive.

Specified by:

setTransportFilter in interface Transport

Parameters:

tracer_ - A TransportFilter instance such as com.crankuptheamps.client.TransportTraceFilter.

getIdleRunnable

public AMPSRunnable getIdleRunnable()

Description copied from interface: Transport

Gets the AMPSRunnable that is invoked during idle-time processing for this connection.

Specified by:

getIdleRunnable in interface Transport

Returns:

The currently registered idle runnable or null.

setIdleRunnable

public void setIdleRunnable(AMPSRunnable runnable)

Description copied from interface: Transport

Sets a AMPSRunnable that is invoked during idle-time processing for this connection.

Specified by:

setIdleRunnable in interface Transport

Parameters:

runnable - A AMPSRunnable instance whose run() method is invoked.

initFromClient

public void initFromClient(Client client)

Description copied from interface: Transport

Called by Client before calling connect to give Transport access to any information in the Client needed by the Transport such as message handler, exceptionListener, etc.

Specified by:

initFromClient in interface Transport

Parameters:

client - The Client that will be using the Transport.

setBatchSend

public void setBatchSend(int batchSendBytes,
                         int timeoutMillis,
                         boolean clear)
                  throws DisconnectedException

Throws:

DisconnectedException