| Package | Description |
|---|---|
| org.infinispan.remoting.inboundhandler |
Handling of inbound commands on remote nodes.
|
| Modifier and Type | Field and Description |
|---|---|
static Reply |
Reply.NO_OP |
protected Reply |
BaseBlockingRunnable.reply |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
AbstractDelegatingHandler.beforeHandle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Invoked before the command is handled by the real
PerCacheInboundInvocationHandler. |
void |
AbstractDelegatingHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
NonTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
PerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Handles the
CacheRpcCommand from other node. |
void |
TrianglePerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
TxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
GlobalInboundInvocationHandler.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order) |
void |
InboundInvocationHandler.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from other node belonging to local site. |
void |
GlobalInboundInvocationHandler.handleFromRemoteSite(String origin,
XSiteReplicateCommand command,
Reply reply,
DeliverOrder order) |
void |
InboundInvocationHandler.handleFromRemoteSite(String origin,
XSiteReplicateCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from remote site. |
| Constructor and Description |
|---|
BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply,
boolean sync) |
DefaultTopologyRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply,
TopologyMode topologyMode,
int commandTopologyId,
boolean sync) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.