AMPS.Client.TCPTransport Class Reference

Inheritance diagram for AMPS.Client.TCPTransport:

Public Member Functions
	TCPTransport (Protocol msgType, Properties properties)
	TCPTransport (Protocol msgType, TCPTransportImpl impl)
void	setIdleAction (Action idleAction)
void	setMessageHandler (MessageHandler ml)
void	setDisconnectHandler (TransportDisconnectHandler dh)
void	setExceptionListener (TCPTransportImpl.ExceptionListener exceptionListener)
void	setThreadCreatedHandler (ThreadCreatedHandler handler)
void	setTransportFilter (TransportFilter filter_)
	Sets a TransportFilter that filters raw bytes bfeore send and after receive. More...
void	setReadTimeout (int readTimeoutMillis_)
void	connect (Uri uri)
	Connect to an AMPS server. More...
void	close ()
void	disconnect ()
void	handleCloseEvent (int failedVersion, String message, Exception exception)
void	sendWithoutRetry (Message message)
void	send (Message message)
Message	allocateMessage ()
long	writeQueueSize ()
long	readQueueSize ()
long	flush ()
long	flush (long timeout)
Socket	socket ()
int	getVersion ()

Static Public Member Functions
static TCPTransport	createTransport (Protocol messageType, TCPTransportImpl impl)
static void	setDefaultConnectTimeout (int defaultConnectTimeoutMillis_)
	Sets the default connect timeout used for new connections. More...
static int	getDefaultConnectTimeout ()
	Returns the default connect timeout used for new connections. More...

Protected Member Functions
virtual void	createImpl ()

Protected Attributes
TCPTransportImpl	impl = null
Protocol	protocol = null
Uri	uri = null
object	sendLock = new object()
MemoryStream	sendBuffer = new MemoryStream(4096)
Properties	properties = null

Static Protected Attributes
static int	_defaultConnectTimeout = 0

Member Function Documentation

connect()

void AMPS.Client.TCPTransport.connect ( Uri  uri )

inline

Connect to an AMPS server.

Parameters

uri	Specifies the protocol and address of the server

Exceptions

ConnectionRefusedException

Exceptions AlreadyConnectedException

Implements AMPS.Client.Transport.

flush()

long AMPS.Client.TCPTransport.flush ( long  timeout )

inline

Returns

Exceptions

DisconnectedException

Implements AMPS.Client.Transport.

getDefaultConnectTimeout()

static int AMPS.Client.TCPTransport.getDefaultConnectTimeout ( )

inlinestatic

Returns the default connect timeout used for new connections.

Returns

The default connect timeout in milliseconds. A 0 value means no timeout is specified, i.e. wait until the OS returns an error.

readQueueSize()

long AMPS.Client.TCPTransport.readQueueSize ( )

inline

Returns

Exceptions

DisconnectedException

Implements AMPS.Client.Transport.

send()

void AMPS.Client.TCPTransport.send ( Message  message )

inline

Parameters

message

Exceptions

DisconnectedException

Implements AMPS.Client.Transport.

setDefaultConnectTimeout()

static void AMPS.Client.TCPTransport.setDefaultConnectTimeout ( int  defaultConnectTimeoutMillis_ )

inlinestatic

Sets the default connect timeout used for new connections.

Parameters

defaultConnectTimeoutMillis_

The default connect timeout, in milliseconds. A 0 value means no timeout is specified, i.e. wait until the OS returns an error.

setTransportFilter()

void AMPS.Client.TCPTransport.setTransportFilter ( TransportFilter  filter_ )

inline

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

Parameters

filter_

A TransportFilter such as AMPS.Client.TransportTraceFilter.

Implements AMPS.Client.Transport.

writeQueueSize()

long AMPS.Client.TCPTransport.writeQueueSize ( )

inline

Returns

Exceptions

DisconnectedException

Implements AMPS.Client.Transport.

---

The documentation for this class was generated from the following file:

• AMPS.Client/TCPTransport.cs