Package 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	Description
static final Map<String,Object>	DEFAULT_CONFIG
protected final OrderedExecutorFactory	executorFactory
static boolean	failOnCreateConnection
protected final int	id
static String	INVM_CONNECTOR_TYPE
static int	numberOfFailures

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

configuration

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
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, ArtemisExecutor 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()
static void	resetFailures()
static void	resetThreadPool()
void	start()

Methods inherited from class java.lang.Object

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

Field Details

INVM_CONNECTOR_TYPE

public static String INVM_CONNECTOR_TYPE

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 Details

InVMConnector

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

Method Details

resetFailures

public static void resetFailures()

resetThreadPool

public static void resetThreadPool()

getAcceptor

public Acceptor getAcceptor()

close

public void close()

isStarted

public boolean isStarted()

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()

getHandler

public BufferHandler getHandler()

disconnect

public void disconnect(String connectionID)

internalCreateConnection

protected Connection internalCreateConnection(BufferHandler handler,
 ClientConnectionLifeCycleListener listener,
 ArtemisExecutor 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