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:

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

public class InVMConnector
extends org.apache.activemq.artemis.spi.core.remoting.AbstractConnector

Field Summary

Fields

Modifier and Type	Field and Description
static Map<String,Object>	DEFAULT_CONFIG
protected org.apache.activemq.artemis.utils.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, org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler, org.apache.activemq.artemis.spi.core.remoting.ClientConnectionLifeCycleListener listener, Executor closeExecutor, Executor threadPool, org.apache.activemq.artemis.spi.core.remoting.ClientProtocolManager protocolManager)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.activemq.artemis.spi.core.remoting.Connection	createConnection()
void	disconnect(String connectionID)
Acceptor	getAcceptor()
org.apache.activemq.artemis.spi.core.remoting.BufferHandler	getHandler()
protected org.apache.activemq.artemis.spi.core.remoting.Connection	internalCreateConnection(org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler, org.apache.activemq.artemis.spi.core.remoting.ClientConnectionLifeCycleListener listener, Executor serverExecutor)
boolean	isEquivalent(Map<String,Object> configuration)
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 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 org.apache.activemq.artemis.utils.OrderedExecutorFactory executorFactory

Constructor Detail

InVMConnector

public InVMConnector(Map<String,Object> configuration,
                     org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler,
                     org.apache.activemq.artemis.spi.core.remoting.ClientConnectionLifeCycleListener listener,
                     Executor closeExecutor,
                     Executor threadPool,
                     org.apache.activemq.artemis.spi.core.remoting.ClientProtocolManager protocolManager)

Method Detail

resetFailures

public static void resetFailures()

resetThreadPool

public static void resetThreadPool()

getAcceptor

public Acceptor getAcceptor()

close

public void close()

isStarted

public boolean isStarted()

createConnection

public org.apache.activemq.artemis.spi.core.remoting.Connection createConnection()

start

public void start()

getHandler

public org.apache.activemq.artemis.spi.core.remoting.BufferHandler getHandler()

disconnect

public void disconnect(String connectionID)

internalCreateConnection

protected org.apache.activemq.artemis.spi.core.remoting.Connection internalCreateConnection(org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler,
                                                                                            org.apache.activemq.artemis.spi.core.remoting.ClientConnectionLifeCycleListener listener,
                                                                                            Executor serverExecutor)

isEquivalent

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