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_REMOTING |
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 |
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_PATH_PROP_NAME
public static final String HORNETQ_KEYSTORE_PASSWORD_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
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 © 2015 JBoss, a division of Red Hat. All rights reserved.