public class TCPTransport extends java.lang.Object implements Transport
Modifier and Type | Field and Description |
---|---|
protected TCPTransportImpl |
_impl |
Constructor and Description |
---|
TCPTransport(Protocol msgType) |
TCPTransport(Protocol protocol,
java.util.Properties properties) |
Modifier and Type | Method and Description |
---|---|
Message |
allocateMessage() |
void |
close() |
void |
connect(java.net.URI uri) |
protected TCPTransportImpl |
constructTransportImpl(Protocol protocol,
java.util.Properties properties) |
static TCPTransport |
createTransport(Protocol messageType) |
void |
disconnect() |
long |
flush() |
long |
flush(long timeout) |
static int |
getDefaultConnectTimeout()
Returns the default connect timeout used for new connections.
|
static int |
getDefaultReadTimeout()
Returns the default read timeout used for socket reads.
|
int |
getVersion() |
void |
handleCloseEvent(int failedVersion_,
java.lang.String message,
java.lang.Exception e) |
static boolean |
isDaemon() |
long |
readQueueSize() |
void |
send(Message message) |
void |
sendWithoutRetry(Message message) |
static void |
setDaemon(boolean daemonThreads) |
static void |
setDefaultConnectTimeout(int defaultConnectTimeoutMillis_)
Returns the default connect timeout used for new connections.
|
static void |
setDefaultReadTimeout(int defaultReadTimeoutMillis_)
Sets the default read timeout used for socket reads.
|
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 readTimeout_) |
void |
setThreadCreatedHandler(ThreadCreatedHandler tch_) |
void |
setTransportFilter(TransportFilter filter)
Sets a TransportFilter that filters raw bytes before send and after receive.
|
java.net.Socket |
socket() |
long |
writeQueueSize() |
protected TCPTransportImpl _impl
public TCPTransport(Protocol protocol, java.util.Properties properties)
public TCPTransport(Protocol msgType)
protected TCPTransportImpl constructTransportImpl(Protocol protocol, java.util.Properties properties)
public static void setDaemon(boolean daemonThreads)
public static boolean isDaemon()
public static void setDefaultReadTimeout(int defaultReadTimeoutMillis_)
defaultReadTimeoutMillis_
- The default read timeout in milliseconds.public static int getDefaultReadTimeout()
public static void setDefaultConnectTimeout(int defaultConnectTimeoutMillis_)
defaultConnectTimeoutMillis_
- The default connect timeout,
in milliseconds. A 0 value means no timeout is specified, i.e. wait
until the OS returns an error.public static int getDefaultConnectTimeout()
public static TCPTransport createTransport(Protocol messageType)
public void setMessageHandler(MessageHandler ml)
setMessageHandler
in interface Transport
public void setThreadCreatedHandler(ThreadCreatedHandler tch_)
setThreadCreatedHandler
in interface Transport
public void setDisconnectHandler(TransportDisconnectHandler dh)
setDisconnectHandler
in interface Transport
public void setExceptionListener(java.beans.ExceptionListener exceptionListener)
setExceptionListener
in interface Transport
public void setTransportFilter(TransportFilter filter)
Transport
setTransportFilter
in interface Transport
filter
- A TransportFilter instance such as com.crankuptheamps.client.TransportTraceFilter.public void connect(java.net.URI uri) throws ConnectionRefusedException, AlreadyConnectedException, InvalidURIException
connect
in interface Transport
ConnectionRefusedException
AlreadyConnectedException
InvalidURIException
public void close() throws java.lang.Exception
close
in interface java.lang.AutoCloseable
java.lang.Exception
public void disconnect()
disconnect
in interface Transport
public void handleCloseEvent(int failedVersion_, java.lang.String message, java.lang.Exception e) throws DisconnectedException, RetryOperationException
handleCloseEvent
in interface Transport
DisconnectedException
RetryOperationException
public void sendWithoutRetry(Message message) throws DisconnectedException
sendWithoutRetry
in interface Transport
DisconnectedException
public void send(Message message) throws DisconnectedException
send
in interface Transport
DisconnectedException
public Message allocateMessage()
allocateMessage
in interface Transport
public long writeQueueSize() throws DisconnectedException
writeQueueSize
in interface Transport
DisconnectedException
public long readQueueSize() throws DisconnectedException
readQueueSize
in interface Transport
DisconnectedException
public long flush() throws DisconnectedException
flush
in interface Transport
DisconnectedException
public long flush(long timeout) throws DisconnectedException
flush
in interface Transport
DisconnectedException
public java.net.Socket socket()
public int getVersion()
getVersion
in interface Transport
public void setReadTimeout(int readTimeout_)
setReadTimeout
in interface Transport
public void setIdleRunnable(AMPSRunnable runnable)
Transport
AMPSRunnable
that is invoked during idle-time processing for this connection.setIdleRunnable
in interface Transport
runnable
- A AMPSRunnable
instance whose run() method is invoked.