public interface RemotingService
Modifier and Type | Method and Description |
---|---|
void |
addIncomingInterceptor(BaseInterceptor interceptor) |
void |
addOutgoingInterceptor(BaseInterceptor interceptor) |
void |
allowInvmSecurityOverride(ActiveMQPrincipal principal)
Allow acceptors to use this as their default security Principal if applicable.
|
Acceptor |
createAcceptor(String name,
String uri) |
Acceptor |
createAcceptor(TransportConfiguration transportConfiguration) |
void |
destroyAcceptor(String name) |
void |
freeze(String scaleDownNodeID,
CoreRemotingConnection remotingConnection)
Freezes and then disconnects all connections except the given one and tells the client where else
it might connect (only applicable if server is in a cluster and uses scaleDown-on-failover=true).
|
Acceptor |
getAcceptor(String name)
Returns the acceptor identified by its
name or null if it does not exists. |
ReusableLatch |
getConnectionCountLatch() |
Set<RemotingConnection> |
getConnections() |
List<BaseInterceptor> |
getIncomingInterceptors() |
List<BaseInterceptor> |
getOutgoinInterceptors() |
long |
getTotalConnectionCount() |
boolean |
isPaused()
Pauses the acceptors so that no more connections can be made to the server
|
boolean |
isStarted() |
void |
pauseAcceptors()
Pauses the acceptors so that no more connections can be made to the server
|
RemotingConnection |
removeConnection(Object remotingConnectionID)
Remove a connection from the connections held by the remoting service.
|
boolean |
removeIncomingInterceptor(BaseInterceptor interceptor) |
boolean |
removeOutgoingInterceptor(BaseInterceptor interceptor) |
void |
start() |
void |
startAcceptors() |
void |
stop(boolean criticalError) |
RemotingConnection removeConnection(Object remotingConnectionID)
remotingConnectionID
- the ID of the RemotingConnection to removedSet<RemotingConnection> getConnections()
long getTotalConnectionCount()
ReusableLatch getConnectionCountLatch()
void addIncomingInterceptor(BaseInterceptor interceptor)
List<BaseInterceptor> getIncomingInterceptors()
void addOutgoingInterceptor(BaseInterceptor interceptor)
List<BaseInterceptor> getOutgoinInterceptors()
boolean removeIncomingInterceptor(BaseInterceptor interceptor)
boolean removeOutgoingInterceptor(BaseInterceptor interceptor)
boolean isStarted()
void allowInvmSecurityOverride(ActiveMQPrincipal principal)
Used by AS7 integration code.
principal
- void pauseAcceptors()
boolean isPaused()
void freeze(String scaleDownNodeID, CoreRemotingConnection remotingConnection)
scaleDownNodeID
- remotingConnection
- Acceptor getAcceptor(String name)
name
or null
if it does not exists.name
- the name of the acceptorAcceptor createAcceptor(TransportConfiguration transportConfiguration)
Copyright © 2017 JBoss by Red Hat. All rights reserved.