Module com.aoapps.messaging.tcp

Package com.aoapps.messaging.tcp

Class TcpSocket

java.lang.Object

com.aoapps.messaging.base.AbstractSocket

com.aoapps.messaging.tcp.TcpSocket

All Implemented Interfaces:

Socket, Closeable, AutoCloseable

public class TcpSocket
extends AbstractSocket

One established connection over a socket.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PROTOCOL

Constructor Summary

Constructors

Constructor	Description
TcpSocket(AbstractSocketContext<? extends AbstractSocket> socketContext, Identifier id, long connectTime, Socket socket, StreamableInput in, StreamableOutput out)	Creates a new TCP socket.

Method Summary

Modifier and Type	Method	Description
void	close()
String	getProtocol()
protected void	sendMessagesImpl(Collection<? extends Message> messages)
protected void	startImpl(Callback<? super Socket> onStart, Callback<? super Throwable> onError)

Methods inherited from class com.aoapps.messaging.base.AbstractSocket

addSocketListener, callOnError, callOnMessages, getCloseTime, getConnectRemoteSocketAddress, getConnectTime, getId, getRemoteSocketAddress, getSocketContext, isClosed, removeSocketListener, sendMessage, sendMessages, setRemoteSocketAddress, start, toString

Methods inherited from class java.lang.Object

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

Field Details

PROTOCOL

public static final String PROTOCOL

See Also:

• Constant Field Values

Constructor Details

TcpSocket

public TcpSocket(AbstractSocketContext<? extends AbstractSocket> socketContext,
 Identifier id,
 long connectTime,
 Socket socket,
 StreamableInput in,
 StreamableOutput out)

Creates a new TCP socket.

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Socket

Overrides:

close in class AbstractSocket

Throws:

IOException

getProtocol

public String getProtocol()

Specified by:

getProtocol in interface Socket

Specified by:

getProtocol in class AbstractSocket

startImpl

protected void startImpl(Callback<? super Socket> onStart,
 Callback<? super Throwable> onError)
                  throws IllegalStateException

Specified by:

startImpl in class AbstractSocket

Throws:

IllegalStateException

sendMessagesImpl

protected void sendMessagesImpl(Collection<? extends Message> messages)

Specified by:

sendMessagesImpl in class AbstractSocket