org.hornetq.core.remoting.impl.invm

Class InVMConnector

java.lang.Object

org.hornetq.core.remoting.impl.invm.InVMConnector

All Implemented Interfaces:

Connector

public class InVMConnector
extends Object
implements Connector

A InVMConnector

Author:

Tim Fox

Field Summary

Fields

Modifier and Type	Field and Description
protected OrderedExecutorFactory	executorFactory
static boolean	failOnCreateConnection
protected int	id
static Logger	log
static int	numberOfFailures

Constructor Summary

Constructors

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

Method Summary

Methods

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, ConnectionLifeCycleListener listener, Executor serverExecutor)
boolean	isStarted() returns true if the connector is started, oterwise false.
static void	resetFailures()
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

log

public static final Logger log

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,
             ConnectionLifeCycleListener listener,
             Executor closeExecutor,
             Executor threadPool)

Method Detail

resetFailures

public static void resetFailures()

getAcceptor

public Acceptor getAcceptor()

close

public void close()

Description copied from interface: Connector

closes the connector

Specified by:

close in interface Connector

isStarted

public boolean isStarted()

Description copied from interface: Connector

returns true if the connector is started, oterwise false.

Specified by:

isStarted in interface Connector

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

Specified by:

createConnection in interface Connector

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

Specified by:

start in interface Connector

getHandler

public BufferHandler getHandler()

disconnect

public void disconnect(String connectionID)

internalCreateConnection

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