public class GlobalInboundInvocationHandler extends Object implements InboundInvocationHandler
InboundInvocationHandler
implementation that handles all the ReplicableCommand
.
This component handles the ReplicableCommand
from local and remote site. The remote
site ReplicableCommand
are sent to the BackupReceiver
to
be handled.
Also, the non-CacheRpcCommand
are processed directly and the CacheRpcCommand
are processed in the cache's PerCacheInboundInvocationHandler
implementation.Constructor and Description |
---|
GlobalInboundInvocationHandler() |
Modifier and Type | Method and Description |
---|---|
void |
cacheStopped(CacheStoppedEvent event) |
ByteString |
getLocalCacheForRemoteSite(String remoteSite,
ByteString remoteCache)
test only! See BackupCacheStoppedTest
|
void |
handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from other node belonging to local site. |
void |
handleFromRemoteSite(String origin,
XSiteReplicateCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from remote site. |
void |
start() |
void |
stop() |
public void start()
public void stop()
public void cacheStopped(CacheStoppedEvent event)
public void handleFromCluster(Address origin, ReplicableCommand command, Reply reply, DeliverOrder order)
InboundInvocationHandler
ReplicableCommand
from other node belonging to local site.handleFromCluster
in interface InboundInvocationHandler
origin
- the sender Address
command
- the ReplicableCommand
to handlerreply
- the return value is passed to this object in order to be sent back to the originorder
- the DeliverOrder
in which the command was sentpublic void handleFromRemoteSite(String origin, XSiteReplicateCommand command, Reply reply, DeliverOrder order)
InboundInvocationHandler
ReplicableCommand
from remote site.handleFromRemoteSite
in interface InboundInvocationHandler
origin
- the sender sitecommand
- the ReplicableCommand
to handlereply
- the return value is passed to this object in order to be sent back to the originorder
- the DeliverOrder
in which the command was sentpublic ByteString getLocalCacheForRemoteSite(String remoteSite, ByteString remoteCache)
Copyright © 2021 JBoss by Red Hat. All rights reserved.