public class InVMConnection extends Object implements Connection
Constructor and Description |
---|
InVMConnection(int serverID,
BufferHandler handler,
BaseConnectionLifeCycleListener listener,
Executor executor) |
InVMConnection(int serverID,
String id,
BufferHandler handler,
BaseConnectionLifeCycleListener listener,
Executor executor) |
InVMConnection(int serverID,
String id,
BufferHandler handler,
BaseConnectionLifeCycleListener listener,
Executor executor,
ActiveMQPrincipal defaultActiveMQPrincipal) |
Modifier and Type | Method and Description |
---|---|
void |
checkFlushBatchBuffer() |
void |
close() |
ActiveMQBuffer |
createTransportBuffer(int size) |
void |
fireReady(boolean ready) |
void |
forceClose() |
int |
getBatchingBufferSize() |
TransportConfiguration |
getConnectorConfig() |
ActiveMQPrincipal |
getDefaultActiveMQPrincipal() |
Executor |
getExecutor() |
Object |
getID() |
String |
getLocalAddress() |
RemotingConnection |
getProtocolConnection() |
String |
getRemoteAddress() |
boolean |
isUsingProtocolHandling() |
boolean |
isWritable(ReadyListener listener) |
void |
setAutoRead(boolean autoRead) |
void |
setEnableBufferPooling(boolean enableBufferPooling) |
static void |
setFlushEnabled(boolean enable) |
void |
setProtocolConnection(RemotingConnection connection) |
String |
toString() |
void |
write(ActiveMQBuffer buffer) |
void |
write(ActiveMQBuffer buffer,
boolean flush,
boolean batch) |
void |
write(ActiveMQBuffer buffer,
boolean flush,
boolean batch,
io.netty.channel.ChannelFutureListener futureListener) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
blockUntilWritable
public InVMConnection(int serverID, BufferHandler handler, BaseConnectionLifeCycleListener listener, Executor executor)
public InVMConnection(int serverID, String id, BufferHandler handler, BaseConnectionLifeCycleListener listener, Executor executor)
public InVMConnection(int serverID, String id, BufferHandler handler, BaseConnectionLifeCycleListener listener, Executor executor, ActiveMQPrincipal defaultActiveMQPrincipal)
public void setEnableBufferPooling(boolean enableBufferPooling)
public void forceClose()
forceClose
in interface Connection
public boolean isWritable(ReadyListener listener)
isWritable
in interface Connection
public void fireReady(boolean ready)
fireReady
in interface Connection
public RemotingConnection getProtocolConnection()
getProtocolConnection
in interface Connection
public void setProtocolConnection(RemotingConnection connection)
setProtocolConnection
in interface Connection
public void close()
close
in interface Connection
public void setAutoRead(boolean autoRead)
setAutoRead
in interface Connection
public ActiveMQBuffer createTransportBuffer(int size)
createTransportBuffer
in interface Connection
public Object getID()
getID
in interface Connection
public void checkFlushBatchBuffer()
checkFlushBatchBuffer
in interface Connection
public void write(ActiveMQBuffer buffer)
write
in interface Connection
public void write(ActiveMQBuffer buffer, boolean flush, boolean batch)
write
in interface Connection
public void write(ActiveMQBuffer buffer, boolean flush, boolean batch, io.netty.channel.ChannelFutureListener futureListener)
write
in interface Connection
public String getRemoteAddress()
getRemoteAddress
in interface Connection
public String getLocalAddress()
getLocalAddress
in interface Connection
public int getBatchingBufferSize()
public boolean isUsingProtocolHandling()
isUsingProtocolHandling
in interface Connection
public ActiveMQPrincipal getDefaultActiveMQPrincipal()
getDefaultActiveMQPrincipal
in interface Connection
public static void setFlushEnabled(boolean enable)
public Executor getExecutor()
public TransportConfiguration getConnectorConfig()
getConnectorConfig
in interface Connection
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.