org.apache.activemq.artemis.core.remoting.impl.netty

Class NettyConnector

java.lang.Object

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

org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnector

All Implemented Interfaces:

Connector

public class NettyConnector
extends AbstractConnector

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTIVEMQ_KEYSTORE_PASSWORD_PROP_NAME
static String	ACTIVEMQ_KEYSTORE_PATH_PROP_NAME
static String	ACTIVEMQ_KEYSTORE_PROVIDER_PROP_NAME
static String	ACTIVEMQ_KEYSTORE_TYPE_PROP_NAME
static String	ACTIVEMQ_REMOTING
static String	ACTIVEMQ_TRUSTSTORE_PASSWORD_PROP_NAME
static String	ACTIVEMQ_TRUSTSTORE_PATH_PROP_NAME
static String	ACTIVEMQ_TRUSTSTORE_PROVIDER_PROP_NAME
static String	ACTIVEMQ_TRUSTSTORE_TYPE_PROP_NAME
static Map<String,Object>	DEFAULT_CONFIG
static String	EPOLL_CONNECTOR_TYPE
static String	JAVAX_KEYSTORE_PASSWORD_PROP_NAME
static String	JAVAX_KEYSTORE_PATH_PROP_NAME
static String	JAVAX_KEYSTORE_PROVIDER_PROP_NAME
static String	JAVAX_KEYSTORE_TYPE_PROP_NAME
static String	JAVAX_TRUSTSTORE_PASSWORD_PROP_NAME
static String	JAVAX_TRUSTSTORE_PATH_PROP_NAME
static String	JAVAX_TRUSTSTORE_PROVIDER_PROP_NAME
static String	JAVAX_TRUSTSTORE_TYPE_PROP_NAME
static String	KQUEUE_CONNECTOR_TYPE
static String	MAGIC_NUMBER
static String	NIO_CONNECTOR_TYPE
static String	SEC_ACTIVEMQ_REMOTING_ACCEPT
static String	SEC_ACTIVEMQ_REMOTING_KEY

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

configuration

Constructor Summary

Constructors

Constructor and Description
NettyConnector(Map<String,Object> configuration, BufferHandler handler, BaseConnectionLifeCycleListener<?> listener, Executor closeExecutor, Executor threadPool, ScheduledExecutorService scheduledThreadPool)
NettyConnector(Map<String,Object> configuration, BufferHandler handler, BaseConnectionLifeCycleListener<?> listener, Executor closeExecutor, Executor threadPool, ScheduledExecutorService scheduledThreadPool, ClientProtocolManager protocolManager)
NettyConnector(Map<String,Object> configuration, BufferHandler handler, BaseConnectionLifeCycleListener<?> listener, Executor closeExecutor, Executor threadPool, ScheduledExecutorService scheduledThreadPool, ClientProtocolManager protocolManager, boolean serverConnection)

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.
Connection	createConnection(Consumer<io.netty.channel.ChannelFuture> onConnect) Create and return a connection from this connector.
NettyConnection	createConnection(Consumer<io.netty.channel.ChannelFuture> onConnect, String host, int port)
static String	createExpectedResponse(String magicNumber, String secretKey)
void	finalize()
io.netty.bootstrap.Bootstrap	getBootStrap()
io.netty.channel.group.ChannelGroup	getChannelGroup()
int	getConnectTimeoutMillis()
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	isServerConnection()
boolean	isStarted() returns true if the connector is started, oterwise false.
void	setConnectTimeoutMillis(int connectTimeoutMillis)
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

NIO_CONNECTOR_TYPE

public static String NIO_CONNECTOR_TYPE

EPOLL_CONNECTOR_TYPE

public static String EPOLL_CONNECTOR_TYPE

KQUEUE_CONNECTOR_TYPE

public static String KQUEUE_CONNECTOR_TYPE

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_KEYSTORE_TYPE_PROP_NAME

public static final String JAVAX_KEYSTORE_TYPE_PROP_NAME

See Also:

Constant Field Values

JAVAX_KEYSTORE_PROVIDER_PROP_NAME

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

JAVAX_TRUSTSTORE_TYPE_PROP_NAME

public static final String JAVAX_TRUSTSTORE_TYPE_PROP_NAME

See Also:

Constant Field Values

JAVAX_TRUSTSTORE_PROVIDER_PROP_NAME

public static final String JAVAX_TRUSTSTORE_PROVIDER_PROP_NAME

See Also:

Constant Field Values

ACTIVEMQ_KEYSTORE_PROVIDER_PROP_NAME

public static final String ACTIVEMQ_KEYSTORE_PROVIDER_PROP_NAME

See Also:

Constant Field Values

ACTIVEMQ_KEYSTORE_TYPE_PROP_NAME

public static final String ACTIVEMQ_KEYSTORE_TYPE_PROP_NAME

See Also:

Constant Field Values

ACTIVEMQ_KEYSTORE_PATH_PROP_NAME

public static final String ACTIVEMQ_KEYSTORE_PATH_PROP_NAME

See Also:

Constant Field Values

ACTIVEMQ_KEYSTORE_PASSWORD_PROP_NAME

public static final String ACTIVEMQ_KEYSTORE_PASSWORD_PROP_NAME

See Also:

Constant Field Values

ACTIVEMQ_TRUSTSTORE_PROVIDER_PROP_NAME

public static final String ACTIVEMQ_TRUSTSTORE_PROVIDER_PROP_NAME

See Also:

Constant Field Values

ACTIVEMQ_TRUSTSTORE_TYPE_PROP_NAME

public static final String ACTIVEMQ_TRUSTSTORE_TYPE_PROP_NAME

See Also:

Constant Field Values

ACTIVEMQ_TRUSTSTORE_PATH_PROP_NAME

public static final String ACTIVEMQ_TRUSTSTORE_PATH_PROP_NAME

See Also:

Constant Field Values

ACTIVEMQ_TRUSTSTORE_PASSWORD_PROP_NAME

public static final String ACTIVEMQ_TRUSTSTORE_PASSWORD_PROP_NAME

See Also:

Constant Field Values

MAGIC_NUMBER

public static final String MAGIC_NUMBER

See Also:

Constant Field Values

SEC_ACTIVEMQ_REMOTING_KEY

public static final String SEC_ACTIVEMQ_REMOTING_KEY

See Also:

Constant Field Values

SEC_ACTIVEMQ_REMOTING_ACCEPT

public static final String SEC_ACTIVEMQ_REMOTING_ACCEPT

See Also:

Constant Field Values

ACTIVEMQ_REMOTING

public static final String ACTIVEMQ_REMOTING

See Also:

Constant Field Values

DEFAULT_CONFIG

public static final Map<String,Object> DEFAULT_CONFIG

Constructor Detail

NettyConnector

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

NettyConnector

public NettyConnector(Map<String,Object> configuration,
                      BufferHandler handler,
                      BaseConnectionLifeCycleListener<?> listener,
                      Executor closeExecutor,
                      Executor threadPool,
                      ScheduledExecutorService scheduledThreadPool,
                      ClientProtocolManager protocolManager)

NettyConnector

public NettyConnector(Map<String,Object> configuration,
                      BufferHandler handler,
                      BaseConnectionLifeCycleListener<?> listener,
                      Executor closeExecutor,
                      Executor threadPool,
                      ScheduledExecutorService scheduledThreadPool,
                      ClientProtocolManager protocolManager,
                      boolean serverConnection)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getChannelGroup

public io.netty.channel.group.ChannelGroup getChannelGroup()

isServerConnection

public boolean isServerConnection()

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)

createConnection

public final Connection createConnection(Consumer<io.netty.channel.ChannelFuture> onConnect)

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.
This version can be used for testing purposes.

Parameters:

onConnect - a callback that would be called right after Bootstrap.connect()

Returns:

The connection, or null if unable to create a connection (e.g. network is unavailable)

createConnection

public NettyConnection createConnection(Consumer<io.netty.channel.ChannelFuture> onConnect,
                                        String host,
                                        int port)

getConnectTimeoutMillis

public int getConnectTimeoutMillis()

setConnectTimeoutMillis

public void setConnectTimeoutMillis(int connectTimeoutMillis)

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