org.apache.activemq.artemis.core.remoting.impl.invm

Class InVMConnection

java.lang.Object

org.apache.activemq.artemis.core.remoting.impl.invm.InVMConnection

All Implemented Interfaces:

org.apache.activemq.artemis.spi.core.remoting.Connection

public class InVMConnection
extends Object
implements org.apache.activemq.artemis.spi.core.remoting.Connection

Constructor Summary

Constructors

Constructor and Description
InVMConnection(int serverID, org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler, org.apache.activemq.artemis.spi.core.remoting.BaseConnectionLifeCycleListener listener, Executor executor)
InVMConnection(int serverID, String id, org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler, org.apache.activemq.artemis.spi.core.remoting.BaseConnectionLifeCycleListener listener, Executor executor)
InVMConnection(int serverID, String id, org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler, org.apache.activemq.artemis.spi.core.remoting.BaseConnectionLifeCycleListener listener, Executor executor, org.apache.activemq.artemis.core.security.ActiveMQPrincipal defaultActiveMQPrincipal)

Method Summary

Modifier and Type	Method and Description
void	checkFlushBatchBuffer()
void	close()
org.apache.activemq.artemis.api.core.ActiveMQBuffer	createTransportBuffer(int size)
void	fireReady(boolean ready)
void	forceClose()
int	getBatchingBufferSize()
org.apache.activemq.artemis.api.core.TransportConfiguration	getConnectorConfig()
org.apache.activemq.artemis.core.security.ActiveMQPrincipal	getDefaultActiveMQPrincipal()
Executor	getExecutor()
Object	getID()
String	getLocalAddress()
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection	getProtocolConnection()
String	getRemoteAddress()
boolean	isUsingProtocolHandling()
boolean	isWritable(org.apache.activemq.artemis.spi.core.remoting.ReadyListener listener)
void	setAutoRead(boolean autoRead)
static void	setFlushEnabled(boolean enable)
void	setProtocolConnection(org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection)
String	toString()
void	write(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
void	write(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, boolean flush, boolean batch)
void	write(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, boolean flush, boolean batch, io.netty.channel.ChannelFutureListener futureListener)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

InVMConnection

public InVMConnection(int serverID,
                      org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler,
                      org.apache.activemq.artemis.spi.core.remoting.BaseConnectionLifeCycleListener listener,
                      Executor executor)

InVMConnection

public InVMConnection(int serverID,
                      String id,
                      org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler,
                      org.apache.activemq.artemis.spi.core.remoting.BaseConnectionLifeCycleListener listener,
                      Executor executor)

InVMConnection

public InVMConnection(int serverID,
                      String id,
                      org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler,
                      org.apache.activemq.artemis.spi.core.remoting.BaseConnectionLifeCycleListener listener,
                      Executor executor,
                      org.apache.activemq.artemis.core.security.ActiveMQPrincipal defaultActiveMQPrincipal)

Method Detail

forceClose

public void forceClose()

Specified by:

forceClose in interface org.apache.activemq.artemis.spi.core.remoting.Connection

isWritable

public boolean isWritable(org.apache.activemq.artemis.spi.core.remoting.ReadyListener listener)

Specified by:

isWritable in interface org.apache.activemq.artemis.spi.core.remoting.Connection

fireReady

public void fireReady(boolean ready)

Specified by:

fireReady in interface org.apache.activemq.artemis.spi.core.remoting.Connection

getProtocolConnection

public org.apache.activemq.artemis.spi.core.protocol.RemotingConnection getProtocolConnection()

Specified by:

getProtocolConnection in interface org.apache.activemq.artemis.spi.core.remoting.Connection

setProtocolConnection

public void setProtocolConnection(org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection)

Specified by:

setProtocolConnection in interface org.apache.activemq.artemis.spi.core.remoting.Connection

close

public void close()

Specified by:

close in interface org.apache.activemq.artemis.spi.core.remoting.Connection

setAutoRead

public void setAutoRead(boolean autoRead)

Specified by:

setAutoRead in interface org.apache.activemq.artemis.spi.core.remoting.Connection

createTransportBuffer

public org.apache.activemq.artemis.api.core.ActiveMQBuffer createTransportBuffer(int size)

Specified by:

createTransportBuffer in interface org.apache.activemq.artemis.spi.core.remoting.Connection

getID

public Object getID()

Specified by:

getID in interface org.apache.activemq.artemis.spi.core.remoting.Connection

checkFlushBatchBuffer

public void checkFlushBatchBuffer()

Specified by:

checkFlushBatchBuffer in interface org.apache.activemq.artemis.spi.core.remoting.Connection

write

public void write(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

Specified by:

write in interface org.apache.activemq.artemis.spi.core.remoting.Connection

write

public void write(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer,
                  boolean flush,
                  boolean batch)

Specified by:

write in interface org.apache.activemq.artemis.spi.core.remoting.Connection

write

public void write(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer,
                  boolean flush,
                  boolean batch,
                  io.netty.channel.ChannelFutureListener futureListener)

Specified by:

write in interface org.apache.activemq.artemis.spi.core.remoting.Connection

getRemoteAddress

public String getRemoteAddress()

Specified by:

getRemoteAddress in interface org.apache.activemq.artemis.spi.core.remoting.Connection

getLocalAddress

public String getLocalAddress()

Specified by:

getLocalAddress in interface org.apache.activemq.artemis.spi.core.remoting.Connection

getBatchingBufferSize

public int getBatchingBufferSize()

isUsingProtocolHandling

public boolean isUsingProtocolHandling()

Specified by:

isUsingProtocolHandling in interface org.apache.activemq.artemis.spi.core.remoting.Connection

getDefaultActiveMQPrincipal

public org.apache.activemq.artemis.core.security.ActiveMQPrincipal getDefaultActiveMQPrincipal()

Specified by:

getDefaultActiveMQPrincipal in interface org.apache.activemq.artemis.spi.core.remoting.Connection

setFlushEnabled

public static void setFlushEnabled(boolean enable)

getExecutor

public Executor getExecutor()

getConnectorConfig

public org.apache.activemq.artemis.api.core.TransportConfiguration getConnectorConfig()

Specified by:

getConnectorConfig in interface org.apache.activemq.artemis.spi.core.remoting.Connection

toString

public String toString()

Overrides:

toString in class Object