Package 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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	NettyConnector.HttpHandler

Field Summary

Fields

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

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

configuration

Constructor Summary

Constructors

Constructor	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	Description
static void	clearThreadPools()
void	close()
Connection	createConnection()	Create and return a connection from this connector.
final 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)
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()
void	setConnectTimeoutMillis(int connectTimeoutMillis)
void	start()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

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

ACTIVEMQ_SSL_PASSWORD_CODEC_CLASS_PROP_NAME

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

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 Details

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()

close

public void close()

isStarted

public boolean isStarted()

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

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