public class InVMConnector extends AbstractConnector
Modifier and Type | Field and Description |
---|---|
static Map<String,Object> |
DEFAULT_CONFIG |
protected OrderedExecutorFactory |
executorFactory |
static boolean |
failOnCreateConnection |
protected int |
id |
static int |
numberOfFailures |
configuration
Constructor and Description |
---|
InVMConnector(Map<String,Object> configuration,
BufferHandler handler,
ClientConnectionLifeCycleListener listener,
Executor closeExecutor,
Executor threadPool,
ClientProtocolManager protocolManager) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Connection |
createConnection() |
void |
disconnect(String connectionID) |
Acceptor |
getAcceptor() |
BufferHandler |
getHandler() |
protected Connection |
internalCreateConnection(BufferHandler handler,
ClientConnectionLifeCycleListener listener,
Executor serverExecutor) |
boolean |
isEquivalent(Map<String,Object> configuration) |
boolean |
isStarted() |
static void |
resetFailures() |
static void |
resetThreadPool() |
void |
start() |
public static volatile boolean failOnCreateConnection
public static volatile int numberOfFailures
protected final int id
protected final OrderedExecutorFactory executorFactory
public InVMConnector(Map<String,Object> configuration, BufferHandler handler, ClientConnectionLifeCycleListener listener, Executor closeExecutor, Executor threadPool, ClientProtocolManager protocolManager)
public static void resetFailures()
public static void resetThreadPool()
public Acceptor getAcceptor()
public void close()
public boolean isStarted()
public Connection createConnection()
public void start()
public BufferHandler getHandler()
public void disconnect(String connectionID)
protected Connection internalCreateConnection(BufferHandler handler, ClientConnectionLifeCycleListener listener, Executor serverExecutor)
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.