public interface Connection
Modifier and Type | Method and Description |
---|---|
void |
addReadyListener(ReadyListener listener) |
void |
checkFlushBatchBuffer()
Called periodically to flush any data in the batch buffer
|
void |
close()
closes this connection.
|
HornetQBuffer |
createBuffer(int size)
Create a new HornetQBuffer of the given size.
|
org.hornetq.core.security.HornetQPrincipal |
getDefaultHornetQPrincipal() |
java.lang.Object |
getID()
returns the unique id of this wire.
|
java.lang.String |
getRemoteAddress()
returns a string representation of the remote address this connection is connected to.
|
void |
removeReadyListener(ReadyListener listener) |
void |
write(HornetQBuffer buffer)
writes the buffer to the connection with no flushing or batching
|
void |
write(HornetQBuffer buffer,
boolean flush,
boolean batched)
writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.
|
HornetQBuffer createBuffer(int size)
size
- the size of buffer to createjava.lang.Object getID()
void write(HornetQBuffer buffer, boolean flush, boolean batched)
buffer
- the buffer to writeflush
- whether to flush the buffers onto the wirebatched
- whether the packet is allowed to batched for better performancevoid write(HornetQBuffer buffer)
buffer
- the buffer to writevoid close()
java.lang.String getRemoteAddress()
void checkFlushBatchBuffer()
void addReadyListener(ReadyListener listener)
void removeReadyListener(ReadyListener listener)
org.hornetq.core.security.HornetQPrincipal getDefaultHornetQPrincipal()
Copyright © 2009 Red Hat Inc. All Rights Reserved.