org.infinispan.interceptors.distribution
Class NonTxDistributionInterceptor
java.lang.Object
org.infinispan.commands.AbstractVisitor
org.infinispan.interceptors.base.CommandInterceptor
org.infinispan.interceptors.base.BaseRpcInterceptor
org.infinispan.interceptors.ClusteringInterceptor
org.infinispan.interceptors.distribution.BaseDistributionInterceptor
org.infinispan.interceptors.distribution.NonTxDistributionInterceptor
- All Implemented Interfaces:
- Visitor
- Direct Known Subclasses:
- NonTxConcurrentDistributionInterceptor
public class NonTxDistributionInterceptor
- extends BaseDistributionInterceptor
Handles the distribution of the non-transactional caches.
- Since:
- 5.2
- Author:
- Mircea Markus
Method Summary |
protected Object |
getResponseFromPrimaryOwner(Address primaryOwner,
Map<Address,Response> addressResponseMap)
|
protected Object |
handleLocalWrite(InvocationContext ctx,
WriteCommand command,
org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator rg,
boolean skipL1Invalidation,
boolean sync)
|
protected void |
handleRemoteWrite(InvocationContext ctx,
WriteCommand command,
org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator,
boolean skipL1Invalidation,
boolean sync)
|
protected Object |
handleWriteCommand(InvocationContext ctx,
WriteCommand command,
org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator,
boolean skipRemoteGet,
boolean skipL1Invalidation)
|
void |
start()
|
Object |
visitClearCommand(InvocationContext ctx,
ClearCommand command)
Don't forward in the case of clear commands, just acquire local locks and broadcast. |
Object |
visitGetKeyValueCommand(InvocationContext ctx,
GetKeyValueCommand command)
|
Object |
visitPutKeyValueCommand(InvocationContext ctx,
PutKeyValueCommand command)
|
Methods inherited from class org.infinispan.commands.AbstractVisitor |
visitApplyDeltaCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
NonTxDistributionInterceptor
public NonTxDistributionInterceptor()
start
public void start()
visitGetKeyValueCommand
public Object visitGetKeyValueCommand(InvocationContext ctx,
GetKeyValueCommand command)
throws Throwable
- Specified by:
visitGetKeyValueCommand
in interface Visitor
- Overrides:
visitGetKeyValueCommand
in class AbstractVisitor
- Throws:
Throwable
visitPutKeyValueCommand
public Object visitPutKeyValueCommand(InvocationContext ctx,
PutKeyValueCommand command)
throws Throwable
- Specified by:
visitPutKeyValueCommand
in interface Visitor
- Overrides:
visitPutKeyValueCommand
in class AbstractVisitor
- Throws:
Throwable
visitClearCommand
public Object visitClearCommand(InvocationContext ctx,
ClearCommand command)
throws Throwable
- Don't forward in the case of clear commands, just acquire local locks and broadcast.
- Specified by:
visitClearCommand
in interface Visitor
- Overrides:
visitClearCommand
in class AbstractVisitor
- Throws:
Throwable
handleWriteCommand
protected Object handleWriteCommand(InvocationContext ctx,
WriteCommand command,
org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator,
boolean skipRemoteGet,
boolean skipL1Invalidation)
throws Throwable
- Specified by:
handleWriteCommand
in class BaseDistributionInterceptor
- Throws:
Throwable
handleLocalWrite
protected Object handleLocalWrite(InvocationContext ctx,
WriteCommand command,
org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator rg,
boolean skipL1Invalidation,
boolean sync)
throws Throwable
- Throws:
Throwable
handleRemoteWrite
protected void handleRemoteWrite(InvocationContext ctx,
WriteCommand command,
org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator,
boolean skipL1Invalidation,
boolean sync)
throws Throwable
- Throws:
Throwable
getResponseFromPrimaryOwner
protected Object getResponseFromPrimaryOwner(Address primaryOwner,
Map<Address,Response> addressResponseMap)
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.