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

Class InVMConnector

java.lang.Object

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

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

All Implemented Interfaces:

Connector

public class InVMConnector
extends AbstractConnector

Field Summary

Fields

Modifier and Type	Field and Description
static Map<String,Object>	DEFAULT_CONFIG
protected OrderedExecutorFactory	executorFactory
static boolean	failOnCreateConnection
protected int	id
static int	numberOfFailures

Fields inherited from class org.apache.activemq.artemis.spi.core.remoting.AbstractConnector

configuration

Constructor Summary

Constructors

Constructor and Description
InVMConnector(Map<String,Object> configuration, BufferHandler handler, ClientConnectionLifeCycleListener listener, Executor closeExecutor, Executor threadPool, ClientProtocolManager protocolManager)

Method Summary

Modifier and Type	Method and Description
void	close() closes the connector
Connection	createConnection() Create and return a connection from this connector.
void	disconnect(String connectionID)
Acceptor	getAcceptor()
BufferHandler	getHandler()
protected Connection	internalCreateConnection(BufferHandler handler, ClientConnectionLifeCycleListener listener, Executor serverExecutor)
boolean	isEquivalent(Map<String,Object> configuration) If the configuration is equivalent to this connector, which means if the parameter configuration is used to create a connection to a target node, it will be the same node as of the connections made with this connector.
boolean	isStarted() returns true if the connector is started, oterwise false.
static void	resetFailures()
static void	resetThreadPool()
void	start() starts the connector

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONFIG

public static final Map<String,Object> DEFAULT_CONFIG

failOnCreateConnection

public static volatile boolean failOnCreateConnection

numberOfFailures

public static volatile int numberOfFailures

id

protected final int id

executorFactory

protected final OrderedExecutorFactory executorFactory

Constructor Detail

InVMConnector

public InVMConnector(Map<String,Object> configuration,
                     BufferHandler handler,
                     ClientConnectionLifeCycleListener listener,
                     Executor closeExecutor,
                     Executor threadPool,
                     ClientProtocolManager protocolManager)

Method Detail

resetFailures

public static void resetFailures()

resetThreadPool

public static void resetThreadPool()

getAcceptor

public Acceptor getAcceptor()

close

public void close()

Description copied from interface: Connector

closes the connector

isStarted

public boolean isStarted()

Description copied from interface: Connector

returns true if the connector is started, oterwise false.

Returns:

true if the connector is started

createConnection

public Connection createConnection()

Description copied from interface: Connector

Create and return a connection from this connector.

This method must NOT throw an exception if it fails to create the connection (e.g. network is not available), in this case it MUST return null

Returns:

The connection, or null if unable to create a connection (e.g. network is unavailable)

start

public void start()

Description copied from interface: Connector

starts the connector

getHandler

public BufferHandler getHandler()

disconnect

public void disconnect(String connectionID)

internalCreateConnection

protected Connection internalCreateConnection(BufferHandler handler,
                                              ClientConnectionLifeCycleListener listener,
                                              Executor serverExecutor)

isEquivalent

public boolean isEquivalent(Map<String,Object> configuration)

Description copied from interface: Connector

If the configuration is equivalent to this connector, which means if the parameter configuration is used to create a connection to a target node, it will be the same node as of the connections made with this connector.

Returns:

true means the configuration is equivalent to the connector. false otherwise.