private class DefaultConnectionPool.PooledConnection extends java.lang.Object implements InternalConnection
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicBoolean |
isClosed |
private UsageTrackingInternalConnection |
wrapped |
Constructor and Description |
---|
PooledConnection(UsageTrackingInternalConnection wrapped) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the connection.
|
ByteBuf |
getBuffer(int capacity)
Gets a buffer with the givens capacity.
|
ConnectionDescription |
getDescription()
Gets the description of this connection.
|
boolean |
isClosed()
Returns the closed state of the connection
|
void |
open()
Opens the connection so its ready for use
|
void |
openAsync(SingleResultCallback<java.lang.Void> callback)
Opens the connection so its ready for use
|
boolean |
opened()
Returns if the connection has been opened
|
ResponseBuffers |
receiveMessage(int responseTo)
Receive a response to a sent message from the server.
|
void |
receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback)
Asynchronously receive a response to a sent message from the server.
|
void |
sendMessage(java.util.List<ByteBuf> byteBuffers,
int lastRequestId)
Send a message to the server.
|
void |
sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback)
Asynchronously send a message to the server.
|
private final UsageTrackingInternalConnection wrapped
private final java.util.concurrent.atomic.AtomicBoolean isClosed
PooledConnection(UsageTrackingInternalConnection wrapped)
public void open()
InternalConnection
open
in interface InternalConnection
public void openAsync(SingleResultCallback<java.lang.Void> callback)
InternalConnection
openAsync
in interface InternalConnection
callback
- the callback to be called once the connection has been openedpublic void close()
InternalConnection
close
in interface InternalConnection
public boolean opened()
InternalConnection
opened
in interface InternalConnection
public boolean isClosed()
InternalConnection
isClosed
in interface InternalConnection
public ByteBuf getBuffer(int capacity)
BufferProvider
getBuffer
in interface BufferProvider
capacity
- the size required for the bufferpublic void sendMessage(java.util.List<ByteBuf> byteBuffers, int lastRequestId)
InternalConnection
sendMessage
in interface InternalConnection
byteBuffers
- the list of byte buffers to send.lastRequestId
- the request id of the last message in byteBufferspublic ResponseBuffers receiveMessage(int responseTo)
InternalConnection
receiveMessage
in interface InternalConnection
responseTo
- the request id that this message is a response topublic void sendMessageAsync(java.util.List<ByteBuf> byteBuffers, int lastRequestId, SingleResultCallback<java.lang.Void> callback)
InternalConnection
sendMessageAsync
in interface InternalConnection
byteBuffers
- the list of byte buffers to sendlastRequestId
- the request id of the last message in byteBufferscallback
- the callback to invoke on completionpublic void receiveMessageAsync(int responseTo, SingleResultCallback<ResponseBuffers> callback)
InternalConnection
receiveMessageAsync
in interface InternalConnection
responseTo
- the request id that this message is a response tocallback
- the callback to invoke on completionpublic ConnectionDescription getDescription()
InternalConnection
getDescription
in interface InternalConnection