TCPTransportImpl (AMPS Java Client (5.3.2.1.6d15937f.540279))

java.lang.Object
- com.crankuptheamps.client.TCPTransportImpl

Direct Known Subclasses:

TCPSTransportImpl
```
public class TCPTransportImpl
extends java.lang.Object
```
Socket implementation for TCPTransport. TCP Transport delegates to an instance of this class. This is used internally by the client's transport. There is usually no reason to make direct use of it. Its functionality is best accessed via the client instance.

Field Summary

Fields
Modifier and Type	Field and Description
`protected TransportFilter`	`_filter`
`protected AMPSRunnable`	`_idleRunnable`
`protected java.io.InputStream`	`_inputStream`
`java.util.concurrent.locks.Lock`	`_lock`
`protected java.io.OutputStream`	`_outputStream`
`protected java.net.Socket`	`_socket`

Constructor Summary

Constructors
Constructor and Description

TCPTransportImpl(Protocol messageType, java.util.Properties properties, TransportFilter filter)

Constructors
Constructor and Description
`TCPTransportImpl(Protocol messageType, java.util.Properties properties, TransportFilter filter)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`connect(java.net.URI addr)`
`protected java.net.Socket`	`createSocket()`
`void`	`disconnect()`
`long`	`flush()`
`long`	`flush(long timeout)`
`void`	`handleCloseEvent(int failedVersion, java.lang.String message, java.lang.Exception e_)`
`protected void`	`handshake()`
`long`	`readQueueSize()`
`void`	`send(java.nio.ByteBuffer buf)`
`void`	`setConnectTimeout(int connectTimeoutMillis_)`
`void`	`setDisconnectHandler(TransportDisconnectHandler h)`
`void`	`setExceptionListener(java.beans.ExceptionListener exceptionListener)`
`void`	`setIdleRunnable(AMPSRunnable runnable)`
`void`	`setMessageHandler(MessageHandler h)`
`void`	`setReadTimeout(int readTimeoutMillis_)`
`void`	`setThreadCreatedHandler(ThreadCreatedHandler h)`
`void`	`setTransportFilter(TransportFilter filter)`
`java.net.Socket`	`socket()`
`long`	`writeQueueSize()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_socket
```
protected java.net.Socket _socket
```

_inputStream

protected java.io.InputStream _inputStream

_outputStream

protected java.io.OutputStream _outputStream

_lock

public final java.util.concurrent.locks.Lock _lock

_filter
```
protected TransportFilter _filter
```

_idleRunnable
```
protected AMPSRunnable _idleRunnable
```

Constructor Detail

TCPTransportImpl

public TCPTransportImpl(Protocol messageType,
                        java.util.Properties properties,
                        TransportFilter filter)

Method Detail

setMessageHandler

public void setMessageHandler(MessageHandler h)

setDisconnectHandler

public void setDisconnectHandler(TransportDisconnectHandler h)

setExceptionListener

public void setExceptionListener(java.beans.ExceptionListener exceptionListener)

setThreadCreatedHandler

public void setThreadCreatedHandler(ThreadCreatedHandler h)

setTransportFilter

public void setTransportFilter(TransportFilter filter)

connect

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

Throws:: ConnectionRefusedException; AlreadyConnectedException; InvalidURIException

createSocket

protected java.net.Socket createSocket()
                                throws java.lang.Exception

Throws:: java.lang.Exception

handshake

protected void handshake()
                  throws java.lang.Exception

Throws:: java.lang.Exception

disconnect
```
public void disconnect()
```

send

public void send(java.nio.ByteBuffer buf)
          throws DisconnectedException

Throws:: DisconnectedException

socket
```
public java.net.Socket socket()
```

writeQueueSize
```
public long writeQueueSize()
```

readQueueSize
```
public long readQueueSize()
```

flush
```
public long flush()
```

flush
```
public long flush(long timeout)
```

handleCloseEvent

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

Throws:: RetryOperationException; DisconnectedException

setReadTimeout

public void setReadTimeout(int readTimeoutMillis_)

setConnectTimeout

public void setConnectTimeout(int connectTimeoutMillis_)

setIdleRunnable

public void setIdleRunnable(AMPSRunnable runnable)

Class TCPTransportImpl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

_socket

_inputStream

_outputStream

_lock

_filter

_idleRunnable

Constructor Detail

TCPTransportImpl

Method Detail

setMessageHandler

setDisconnectHandler

setExceptionListener

setThreadCreatedHandler

setTransportFilter

connect

createSocket

handshake

disconnect

send

socket

writeQueueSize

readQueueSize

flush

flush

handleCloseEvent

setReadTimeout

setConnectTimeout

setIdleRunnable