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:

Connection

public class InVMConnection
extends Object
implements Connection

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	checkFlushBatchBuffer() Called periodically to flush any data in the batch buffer
void	close() Closes the connection.
ActiveMQBuffer	createTransportBuffer(int size) Create a new ActiveMQBuffer of the given size.
void	fireReady(boolean ready)
void	forceClose() This should close the internal channel without calling any listeners.
int	getBatchingBufferSize()
TransportConfiguration	getConnectorConfig() Generates a TransportConfiguration to be used to connect to the same target this is connected to.
ActiveMQPrincipal	getDefaultActiveMQPrincipal()
Executor	getExecutor()
Object	getID() returns the unique id of this wire.
String	getLocalAddress() Returns a string representation of the local address this connection is connected to.
RemotingConnection	getProtocolConnection()
String	getRemoteAddress() Returns a string representation of the remote address this connection is connected to.
boolean	isDirectDeliver()
boolean	isOpen()
boolean	isSameTarget(TransportConfiguration... configs)
boolean	isUsingProtocolHandling() the InVM Connection has some special handling as it doesn't use Netty ProtocolChannel we will use this method Instead of using instanceof
boolean	isWritable(ReadyListener listener)
void	setAutoRead(boolean autoRead) This will disable reading from the channel.
void	setDirectDeliver(boolean directDeliver)
void	setEnableBufferPooling(boolean enableBufferPooling)
static void	setFlushEnabled(boolean enable)
void	setProtocolConnection(RemotingConnection connection)
String	toString()
void	write(ActiveMQBuffer buffer) writes the buffer to the connection with no flushing or batching
void	write(ActiveMQBuffer buffer, boolean requestFlush) writes the buffer to the connection and if flush is true request to flush the buffer (and any previous un-flushed ones) into the wire.
void	write(ActiveMQBuffer buffer, boolean flush, boolean batch) writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.
void	write(ActiveMQBuffer buffer, boolean flush, boolean batch, io.netty.channel.ChannelFutureListener futureListener) writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.spi.core.remoting.Connection

blockUntilWritable

Constructor Detail

InVMConnection

public InVMConnection(int serverID,
                      BufferHandler handler,
                      BaseConnectionLifeCycleListener listener,
                      Executor executor)

InVMConnection

public InVMConnection(int serverID,
                      String id,
                      BufferHandler handler,
                      BaseConnectionLifeCycleListener listener,
                      Executor executor)

InVMConnection

public InVMConnection(int serverID,
                      String id,
                      BufferHandler handler,
                      BaseConnectionLifeCycleListener listener,
                      Executor executor,
                      ActiveMQPrincipal defaultActiveMQPrincipal)

Method Detail

setEnableBufferPooling

public void setEnableBufferPooling(boolean enableBufferPooling)

forceClose

public void forceClose()

Description copied from interface: Connection

This should close the internal channel without calling any listeners. This is to avoid a situation where the broker is busy writing on an internal thread. This should close the socket releasing any pending threads.

Specified by:

forceClose in interface Connection

isWritable

public boolean isWritable(ReadyListener listener)

Specified by:

isWritable in interface Connection

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Connection

fireReady

public void fireReady(boolean ready)

Specified by:

fireReady in interface Connection

getProtocolConnection

public RemotingConnection getProtocolConnection()

Specified by:

getProtocolConnection in interface Connection

setProtocolConnection

public void setProtocolConnection(RemotingConnection connection)

Specified by:

setProtocolConnection in interface Connection

close

public void close()

Description copied from interface: Connection

Closes the connection.

Specified by:

close in interface Connection

setAutoRead

public void setAutoRead(boolean autoRead)

Description copied from interface: Connection

This will disable reading from the channel. This is basically the same as blocking the reading.

Specified by:

setAutoRead in interface Connection

createTransportBuffer

public ActiveMQBuffer createTransportBuffer(int size)

Description copied from interface: Connection

Create a new ActiveMQBuffer of the given size.

Specified by:

createTransportBuffer in interface Connection

Parameters:

size - the size of buffer to create

Returns:

the new buffer.

getID

public Object getID()

Description copied from interface: Connection

returns the unique id of this wire.

Specified by:

getID in interface Connection

Returns:

the id

checkFlushBatchBuffer

public void checkFlushBatchBuffer()

Description copied from interface: Connection

Called periodically to flush any data in the batch buffer

Specified by:

checkFlushBatchBuffer in interface Connection

write

public void write(ActiveMQBuffer buffer,
                  boolean requestFlush)

Description copied from interface: Connection

writes the buffer to the connection and if flush is true request to flush the buffer (and any previous un-flushed ones) into the wire.

Specified by:

write in interface Connection

Parameters:

buffer - the buffer to write

requestFlush - whether to request flush onto the wire

write

public void write(ActiveMQBuffer buffer)

Description copied from interface: Connection

writes the buffer to the connection with no flushing or batching

Specified by:

write in interface Connection

Parameters:

buffer - the buffer to write

write

public void write(ActiveMQBuffer buffer,
                  boolean flush,
                  boolean batch)

Description copied from interface: Connection

writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.

Specified by:

write in interface Connection

Parameters:

buffer - the buffer to write

flush - whether to flush the buffers onto the wire

batch - whether the packet is allowed to batched for better performance

write

public void write(ActiveMQBuffer buffer,
                  boolean flush,
                  boolean batch,
                  io.netty.channel.ChannelFutureListener futureListener)

Description copied from interface: Connection

writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.

Specified by:

write in interface Connection

Parameters:

buffer - the buffer to write

flush - whether to flush the buffers onto the wire

batch - whether the packet is allowed to batched for better performance

getRemoteAddress

public String getRemoteAddress()

Description copied from interface: Connection

Returns a string representation of the remote address this connection is connected to.

Specified by:

getRemoteAddress in interface Connection

Returns:

the remote address

getLocalAddress

public String getLocalAddress()

Description copied from interface: Connection

Returns a string representation of the local address this connection is connected to. This is useful when the server is configured at 0.0.0.0 (or multiple IPs). This will give you the actual IP that's being used.

Specified by:

getLocalAddress in interface Connection

Returns:

the local address

getBatchingBufferSize

public int getBatchingBufferSize()

isUsingProtocolHandling

public boolean isUsingProtocolHandling()

Description copied from interface: Connection

the InVM Connection has some special handling as it doesn't use Netty ProtocolChannel we will use this method Instead of using instanceof

Specified by:

isUsingProtocolHandling in interface Connection

Returns:

getDefaultActiveMQPrincipal

public ActiveMQPrincipal getDefaultActiveMQPrincipal()

Specified by:

getDefaultActiveMQPrincipal in interface Connection

setFlushEnabled

public static void setFlushEnabled(boolean enable)

getExecutor

public Executor getExecutor()

getConnectorConfig

public TransportConfiguration getConnectorConfig()

Description copied from interface: Connection

Generates a TransportConfiguration to be used to connect to the same target this is connected to.

Specified by:

getConnectorConfig in interface Connection

Returns:

TransportConfiguration

isDirectDeliver

public boolean isDirectDeliver()

Specified by:

isDirectDeliver in interface Connection

setDirectDeliver

public void setDirectDeliver(boolean directDeliver)

toString

public String toString()

Overrides:

toString in class Object

isSameTarget

public boolean isSameTarget(TransportConfiguration... configs)

Specified by:

isSameTarget in interface Connection