Method Summary |
|
public void | close(SinkIF compQ) Close the connection. |
public void | enqueue(QueueElementIF element) Enqueue outgoing data on this connection. |
public void | enqueue_abort(Object key) |
public void | enqueue_commit(Object key) |
public boolean | enqueue_lossy(QueueElementIF element) Enqueue outgoing data on this connection. |
public void | enqueue_many(QueueElementIF elements) Enqueue outgoing data on this connection. |
public Object | enqueue_prepare(QueueElementIF enqueueMe) |
public void | flush(SinkIF compQ) Flush the connection; a SinkFlushedEvent will be pushed to the
user when all packets have drained. |
public ATcpConnection | getConnection() Return the ATcpConnection associated with this connection. |
void | parsePacket(ATcpInPacket pkt) Package-internal: Parse the data contained in the given TCP packet. |
public int | size() Return the number of outgoing packets waiting to be sent. |
public String | toString() |