org.hornetq.core.remoting.impl.netty

Class NettyConnector

java.lang.Object

org.hornetq.spi.core.remoting.AbstractConnector

org.hornetq.core.remoting.impl.netty.NettyConnector

All Implemented Interfaces:

Connector

public class NettyConnector
extends AbstractConnector

A NettyConnector

Author:

Tim Fox, Trustin Lee

Field Summary

Fields

Modifier and Type	Field and Description
static String	HORNETQ_KEYSTORE_PASSWORD_PROP_NAME
static String	HORNETQ_KEYSTORE_PATH_PROP_NAME
static String	HORNETQ_TRUSTSTORE_PASSWORD_PROP_NAME
static String	HORNETQ_TRUSTSTORE_PATH_PROP_NAME
static String	JAVAX_KEYSTORE_PASSWORD_PROP_NAME
static String	JAVAX_KEYSTORE_PATH_PROP_NAME
static String	JAVAX_TRUSTSTORE_PASSWORD_PROP_NAME
static String	JAVAX_TRUSTSTORE_PATH_PROP_NAME

Fields inherited from class org.hornetq.spi.core.remoting.AbstractConnector

configuration

Constructor Summary

Constructors

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

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	finalize()
org.jboss.netty.bootstrap.ClientBootstrap	getBootStrap()
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.
void	start() starts the connector
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

JAVAX_KEYSTORE_PATH_PROP_NAME

public static final String JAVAX_KEYSTORE_PATH_PROP_NAME

See Also:

Constant Field Values

JAVAX_KEYSTORE_PASSWORD_PROP_NAME

public static final String JAVAX_KEYSTORE_PASSWORD_PROP_NAME

See Also:

Constant Field Values

JAVAX_TRUSTSTORE_PATH_PROP_NAME

public static final String JAVAX_TRUSTSTORE_PATH_PROP_NAME

See Also:

Constant Field Values

JAVAX_TRUSTSTORE_PASSWORD_PROP_NAME

public static final String JAVAX_TRUSTSTORE_PASSWORD_PROP_NAME

See Also:

Constant Field Values

HORNETQ_KEYSTORE_PATH_PROP_NAME

public static final String HORNETQ_KEYSTORE_PATH_PROP_NAME

See Also:

Constant Field Values

HORNETQ_KEYSTORE_PASSWORD_PROP_NAME

public static final String HORNETQ_KEYSTORE_PASSWORD_PROP_NAME

See Also:

Constant Field Values

HORNETQ_TRUSTSTORE_PATH_PROP_NAME

public static final String HORNETQ_TRUSTSTORE_PATH_PROP_NAME

See Also:

Constant Field Values

HORNETQ_TRUSTSTORE_PASSWORD_PROP_NAME

public static final String HORNETQ_TRUSTSTORE_PASSWORD_PROP_NAME

See Also:

Constant Field Values

Constructor Detail

NettyConnector

public NettyConnector(Map<String,Object> configuration,
              BufferHandler handler,
              ConnectionLifeCycleListener listener,
              Executor closeExecutor,
              Executor threadPool,
              ScheduledExecutorService scheduledThreadPool)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

start

public void start()

Description copied from interface: Connector

starts the connector

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)

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.

finalize

public void finalize()
              throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

getBootStrap

public org.jboss.netty.bootstrap.ClientBootstrap getBootStrap()