public class InVMConnection extends Object implements Connection
Constructor and Description |
---|
InVMConnection(int serverID,
BufferHandler handler,
ConnectionLifeCycleListener listener,
Executor executor) |
InVMConnection(int serverID,
String id,
BufferHandler handler,
ConnectionLifeCycleListener listener,
Executor executor) |
InVMConnection(int serverID,
String id,
BufferHandler handler,
ConnectionLifeCycleListener listener,
Executor executor,
HornetQPrincipal defaultHornetQPrincipal) |
Modifier and Type | Method and Description |
---|---|
void |
addReadyListener(ReadyListener listener) |
void |
checkFlushBatchBuffer() |
void |
close() |
HornetQBuffer |
createTransportBuffer(int size) |
void |
forceClose() |
int |
getBatchingBufferSize() |
TransportConfiguration |
getConnectorConfig() |
HornetQPrincipal |
getDefaultHornetQPrincipal() |
Executor |
getExecutor() |
Object |
getID() |
String |
getRemoteAddress() |
void |
removeReadyListener(ReadyListener listener) |
static void |
setFlushEnabled(boolean enable) |
String |
toString() |
void |
write(HornetQBuffer buffer) |
void |
write(HornetQBuffer buffer,
boolean flush,
boolean batch) |
public InVMConnection(int serverID, BufferHandler handler, ConnectionLifeCycleListener listener, Executor executor)
public InVMConnection(int serverID, String id, BufferHandler handler, ConnectionLifeCycleListener listener, Executor executor)
public InVMConnection(int serverID, String id, BufferHandler handler, ConnectionLifeCycleListener listener, Executor executor, HornetQPrincipal defaultHornetQPrincipal)
public void forceClose()
forceClose
in interface Connection
public void close()
close
in interface Connection
public HornetQBuffer createTransportBuffer(int size)
createTransportBuffer
in interface Connection
public Object getID()
getID
in interface Connection
public void checkFlushBatchBuffer()
checkFlushBatchBuffer
in interface Connection
public void write(HornetQBuffer buffer)
write
in interface Connection
public void write(HornetQBuffer buffer, boolean flush, boolean batch)
write
in interface Connection
public String getRemoteAddress()
getRemoteAddress
in interface Connection
public int getBatchingBufferSize()
public void addReadyListener(ReadyListener listener)
addReadyListener
in interface Connection
public void removeReadyListener(ReadyListener listener)
removeReadyListener
in interface Connection
public HornetQPrincipal getDefaultHornetQPrincipal()
getDefaultHornetQPrincipal
in interface Connection
public static void setFlushEnabled(boolean enable)
public Executor getExecutor()
public TransportConfiguration getConnectorConfig()
getConnectorConfig
in interface Connection
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.