Package | Description |
---|---|
org.infinispan.remoting.inboundhandler |
Modifier and Type | Field and Description |
---|---|
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 . |
protected BlockingRunnable |
BasePerCacheInboundInvocationHandler.createDefaultRunnable(CacheRpcCommand command,
Reply reply,
int commandTopologyId,
boolean waitTransactionalData,
boolean onExecutorService) |
protected BlockingRunnable |
NonTotalOrderTxPerCacheInboundInvocationHandler.createReadyActionRunnable(CacheRpcCommand command,
Reply reply,
int commandTopologyId,
boolean waitTransactionalData,
boolean onExecutorService,
ReadyAction readyAction) |
void |
TotalOrderTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
PerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Handles the
CacheRpcCommand from other node. |
void |
NonTotalOrderTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
NonTotalOrderPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
AbstractDelegatingHandler.handle(CacheRpcCommand 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.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order) |
void |
InboundInvocationHandler.handleFromRemoteSite(String origin,
XSiteReplicateCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from remote site. |
void |
GlobalInboundInvocationHandler.handleFromRemoteSite(String origin,
XSiteReplicateCommand command,
Reply reply,
DeliverOrder order) |
Constructor and Description |
---|
BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply) |
DefaultTopologyRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply,
TopologyMode topologyMode,
int commandTopologyId) |
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.