public class NettyConnector extends AbstractConnector
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 |
configuration
Constructor and Description |
---|
NettyConnector(Map<String,Object> configuration,
BufferHandler handler,
ConnectionLifeCycleListener listener,
Executor closeExecutor,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool) |
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() |
public static final String JAVAX_KEYSTORE_PATH_PROP_NAME
public static final String JAVAX_KEYSTORE_PASSWORD_PROP_NAME
public static final String JAVAX_TRUSTSTORE_PATH_PROP_NAME
public static final String JAVAX_TRUSTSTORE_PASSWORD_PROP_NAME
public static final String HORNETQ_KEYSTORE_PROVIDER_PROP_NAME
public static final String HORNETQ_KEYSTORE_PATH_PROP_NAME
public static final String HORNETQ_KEYSTORE_PASSWORD_PROP_NAME
public static final String HORNETQ_TRUSTSTORE_PROVIDER_PROP_NAME
public static final String HORNETQ_TRUSTSTORE_PATH_PROP_NAME
public static final String HORNETQ_TRUSTSTORE_PASSWORD_PROP_NAME
public static final String MAGIC_NUMBER
public static final String SEC_HORNETQ_REMOTING_KEY
public static final String SEC_HORNETQ_REMOTING_ACCEPT
public static final String HORNETQ_REMOTING
public NettyConnector(Map<String,Object> configuration, BufferHandler handler, ConnectionLifeCycleListener listener, Executor closeExecutor, Executor threadPool, ScheduledExecutorService scheduledThreadPool)
public void start()
Connector
public void close()
Connector
public boolean isStarted()
Connector
public Connection createConnection()
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
public boolean isEquivalent(Map<String,Object> configuration)
Connector
public void finalize() throws Throwable
public io.netty.bootstrap.Bootstrap getBootStrap()
public static void clearThreadPools()
public static String createExpectedResponse(String magicNumber, String secretKey) throws IOException
IOException
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.