Class MapOperation
- java.lang.Object
-
- org.redisson.transaction.operation.TransactionalOperation
-
- org.redisson.transaction.operation.map.MapOperation
-
- Direct Known Subclasses:
MapAddAndGetOperation,MapCacheFastPutIfAbsentOperation,MapCacheFastPutOperation,MapCachePutIfAbsentOperation,MapCachePutOperation,MapFastPutIfAbsentOperation,MapFastPutIfExistsOperation,MapFastPutOperation,MapFastRemoveOperation,MapPutIfAbsentOperation,MapPutIfExistsOperation,MapPutOperation,MapRemoveOperation,MapReplaceOperation
public abstract class MapOperation extends TransactionalOperation
- Author:
- Nikita Koksharov
-
-
Field Summary
-
Fields inherited from class org.redisson.transaction.operation.TransactionalOperation
codec, name, threadId
-
-
Constructor Summary
Constructors Constructor Description MapOperation()MapOperation(RMap<?,?> map, Object key, Object value, Object oldValue, String transactionId, long threadId)MapOperation(RMap<?,?> map, Object key, Object value, String transactionId, long threadId)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract voidcommit(RMap<Object,Object> map)voidcommit(CommandAsyncExecutor commandExecutor)ObjectgetKey()protected RLockgetLock(RMap<?,?> map, CommandAsyncExecutor commandExecutor, Object key)RMap<?,?>getMap()protected RMap<Object,Object>getMap(CommandAsyncExecutor commandExecutor)ObjectgetOldValue()ObjectgetValue()voidrollback(CommandAsyncExecutor commandExecutor)-
Methods inherited from class org.redisson.transaction.operation.TransactionalOperation
getCodec, getName, getThreadId
-
-
-
-
Method Detail
-
getKey
public Object getKey()
-
getMap
public RMap<?,?> getMap()
-
commit
public final void commit(CommandAsyncExecutor commandExecutor)
- Specified by:
commitin classTransactionalOperation
-
getMap
protected RMap<Object,Object> getMap(CommandAsyncExecutor commandExecutor)
-
rollback
public void rollback(CommandAsyncExecutor commandExecutor)
- Specified by:
rollbackin classTransactionalOperation
-
getLock
protected RLock getLock(RMap<?,?> map, CommandAsyncExecutor commandExecutor, Object key)
-
getValue
public Object getValue()
-
getOldValue
public Object getOldValue()
-
-