Modifier and Type | Method and Description |
---|---|
ProtocolManager |
ProtocolHandler.getProtocol(String name) |
Constructor and Description |
---|
ProtocolHandler(Map<String,ProtocolManager> protocolMap,
NettyAcceptor nettyAcceptor,
Map<String,Object> configuration,
ScheduledExecutorService scheduledThreadPool) |
Modifier and Type | Class and Description |
---|---|
class |
CoreProtocolManager |
Modifier and Type | Method and Description |
---|---|
ProtocolManager |
CoreProtocolManagerFactory.createProtocolManager(ActiveMQServer server,
Map<String,Object> parameters,
List<BaseInterceptor> incomingInterceptors,
List<BaseInterceptor> outgoingInterceptors)
When you create the ProtocolManager, you should filter out any interceptors that won't belong
to this Protocol.
|
Constructor and Description |
---|
CoreSessionCallback(String name,
ProtocolManager protocolManager,
Channel channel,
RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
ProtocolManager |
HornetQProtocolManagerFactory.createProtocolManager(ActiveMQServer server,
Map<String,Object> parameters,
List<BaseInterceptor> incomingInterceptors,
List<BaseInterceptor> outgoingInterceptors) |
Modifier and Type | Field and Description |
---|---|
protected Map<String,ProtocolManager> |
AbstractAcceptor.protocolMap |
Constructor and Description |
---|
AbstractAcceptor(Map<String,ProtocolManager> protocolMap) |
Modifier and Type | Method and Description |
---|---|
Acceptor |
InVMAcceptorFactory.createAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap) |
Constructor and Description |
---|
InVMAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
Map<String,ProtocolManager> protocolMap,
Executor threadPool) |
Modifier and Type | Method and Description |
---|---|
Acceptor |
NettyAcceptorFactory.createAcceptor(String name,
ClusterConnection connection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap) |
Constructor and Description |
---|
NettyAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap) |
Modifier and Type | Method and Description |
---|---|
void |
RemotingServiceImpl.connectionCreated(ActiveMQComponent component,
Connection connection,
ProtocolManager protocol) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractProtocolManager<P,I extends BaseInterceptor<P>,C extends RemotingConnection> |
Modifier and Type | Method and Description |
---|---|
ProtocolManager |
ProtocolManagerFactory.createProtocolManager(ActiveMQServer server,
Map<String,Object> parameters,
List<BaseInterceptor> incomingInterceptors,
List<BaseInterceptor> outgoingInterceptors)
When you create the ProtocolManager, you should filter out any interceptors that won't belong
to this Protocol.
|
Modifier and Type | Method and Description |
---|---|
Acceptor |
AcceptorFactory.createAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ServerConnectionLifeCycleListener listener,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap)
Create a new instance of an Acceptor.
|
Copyright © 2017 JBoss by Red Hat. All rights reserved.