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, Norman Maurer

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_KEYSTORE_PROVIDER_PROP_NAME
static String	HORNETQ_REMOTING
static String	HORNETQ_TRUSTSTORE_PASSWORD_PROP_NAME
static String	HORNETQ_TRUSTSTORE_PATH_PROP_NAME
static String	HORNETQ_TRUSTSTORE_PROVIDER_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
static String	MAGIC_NUMBER
static String	SEC_HORNETQ_REMOTING_ACCEPT
static String	SEC_HORNETQ_REMOTING_KEY

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

Modifier and Type	Method and Description
static void	clearThreadPools()
void	close() closes the connector
Connection	createConnection() Create and return a connection from this connector.
static String	createExpectedResponse(String magicNumber, String secretKey)
void	finalize()
io.netty.bootstrap.Bootstrap	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_PROVIDER_PROP_NAME

public static final String HORNETQ_KEYSTORE_PROVIDER_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_PROVIDER_PROP_NAME

public static final String HORNETQ_TRUSTSTORE_PROVIDER_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

MAGIC_NUMBER

public static final String MAGIC_NUMBER

See Also:

Constant Field Values

SEC_HORNETQ_REMOTING_KEY

public static final String SEC_HORNETQ_REMOTING_KEY

See Also:

Constant Field Values

SEC_HORNETQ_REMOTING_ACCEPT

public static final String SEC_HORNETQ_REMOTING_ACCEPT

See Also:

Constant Field Values

HORNETQ_REMOTING

public static final String HORNETQ_REMOTING

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 io.netty.bootstrap.Bootstrap getBootStrap()

clearThreadPools

public static void clearThreadPools()

createExpectedResponse

public static String createExpectedResponse(String magicNumber,
                                            String secretKey)
                                     throws IOException

Throws:

IOException