public class RemotingServiceImpl extends Object implements RemotingService, ConnectionLifeCycleListener
Modifier and Type | Field and Description |
---|---|
static long |
CONNECTION_TTL_CHECK_INTERVAL |
Constructor and Description |
---|
RemotingServiceImpl(ClusterManager clusterManager,
Configuration config,
HornetQServer server,
ManagementService managementService,
ScheduledExecutorService scheduledThreadPool,
List<ProtocolManagerFactory> protocolManagerFactories,
Executor flushExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
addIncomingInterceptor(Interceptor interceptor) |
void |
addOutgoingInterceptor(Interceptor interceptor) |
void |
allowInvmSecurityOverride(HornetQPrincipal principal)
Allow acceptors to use this as their default security Principal if applicable.
|
void |
connectionCreated(HornetQComponent component,
Connection connection,
String protocol) |
void |
connectionDestroyed(Object connectionID) |
void |
connectionException(Object connectionID,
HornetQException me) |
void |
connectionReadyForWrites(Object connectionID,
boolean ready) |
void |
freeze(CoreRemotingConnection connectionToKeepOpen)
Freezes and then disconnects all connections except the given one.
|
Acceptor |
getAcceptor(String name)
Returns the acceptor identified by its
name or null if it does not exists. |
Set<RemotingConnection> |
getConnections() |
boolean |
isStarted() |
RemotingConnection |
removeConnection(Object remotingConnectionID)
Remove a connection from the connections held by the remoting service.
|
boolean |
removeIncomingInterceptor(Interceptor interceptor) |
boolean |
removeOutgoingInterceptor(Interceptor interceptor) |
void |
start() |
void |
startAcceptors() |
void |
stop(boolean criticalError) |
public static final long CONNECTION_TTL_CHECK_INTERVAL
public RemotingServiceImpl(ClusterManager clusterManager, Configuration config, HornetQServer server, ManagementService managementService, ScheduledExecutorService scheduledThreadPool, List<ProtocolManagerFactory> protocolManagerFactories, Executor flushExecutor)
public void start() throws Exception
start
in interface RemotingService
Exception
public void startAcceptors() throws Exception
startAcceptors
in interface RemotingService
Exception
public void allowInvmSecurityOverride(HornetQPrincipal principal)
RemotingService
Used by AS7 integration code.
allowInvmSecurityOverride
in interface RemotingService
public void freeze(CoreRemotingConnection connectionToKeepOpen)
RemotingService
freeze
in interface RemotingService
public void stop(boolean criticalError) throws Exception
stop
in interface RemotingService
Exception
public Acceptor getAcceptor(String name)
RemotingService
name
or null
if it does not exists.getAcceptor
in interface RemotingService
name
- the name of the acceptorpublic boolean isStarted()
isStarted
in interface RemotingService
public RemotingConnection removeConnection(Object remotingConnectionID)
RemotingService
removeConnection
in interface RemotingService
remotingConnectionID
- the ID of the RemotingConnection to removedpublic Set<RemotingConnection> getConnections()
getConnections
in interface RemotingService
public void connectionCreated(HornetQComponent component, Connection connection, String protocol)
connectionCreated
in interface ConnectionLifeCycleListener
public void connectionDestroyed(Object connectionID)
connectionDestroyed
in interface ConnectionLifeCycleListener
public void connectionException(Object connectionID, HornetQException me)
connectionException
in interface ConnectionLifeCycleListener
public void connectionReadyForWrites(Object connectionID, boolean ready)
connectionReadyForWrites
in interface ConnectionLifeCycleListener
public void addIncomingInterceptor(Interceptor interceptor)
addIncomingInterceptor
in interface RemotingService
public boolean removeIncomingInterceptor(Interceptor interceptor)
removeIncomingInterceptor
in interface RemotingService
public void addOutgoingInterceptor(Interceptor interceptor)
addOutgoingInterceptor
in interface RemotingService
public boolean removeOutgoingInterceptor(Interceptor interceptor)
removeOutgoingInterceptor
in interface RemotingService
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.