public class RedisTransactionalMethods
extends io.toro.martini.redis.RedisBaseMethods
Constructor and Description |
---|
RedisTransactionalMethods(DataSourceManager dataSourceManager) |
Modifier and Type | Method and Description |
---|---|
static String |
discard(String connectionName,
GloopExecutionContext context)
Discard all commands issued after MULTI.
|
static Future<String> |
discardAsync(String connectionName,
GloopExecutionContext context)
Asynchronously discard all commands issued after mULTI.
|
static TransactionResult |
exec(String connectionName,
GloopExecutionContext context)
Execute all commands issued after MULTI.
|
static Future<TransactionResult> |
execAsync(String connectionName,
GloopExecutionContext context)
Asynchronously execute all commands issued after mULTI.
|
static String |
multi(String connectionName,
GloopExecutionContext context)
Mark the start of a transaction block.
|
static Future<String> |
multiAsync(String connectionName,
GloopExecutionContext context)
Asynchronously mark the start of a transaction block.
|
static String |
unwatch(String connectionName,
GloopExecutionContext context)
Forget about all watched keys.
|
static Future<String> |
unwatchAsync(String connectionName,
GloopExecutionContext context)
Asynchronously forget about all watched keys.
|
static String |
watch(String connectionName,
GloopExecutionContext context,
Object... keys)
Watch the given keys to determine execution of the MULTI/EXEC block.
|
static Future<String> |
watchAsync(String connectionName,
GloopExecutionContext context,
Object... keys)
Asynchronously watch the given keys to determine execution of the mULTI/EXEC block.
|
@Autowired RedisTransactionalMethods(DataSourceManager dataSourceManager)
@GloopParameter(name="redisDiscardOutput") public static String discard(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool nameOK
.@GloopParameter(name="redisFutureDiscardOutput") public static Future<String> discardAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool nameoK
.@GloopParameter(name="redisExecOutput") public static TransactionResult exec(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool nameWATCH
, EXEC
can return a@GloopParameter(name="redisFutureExecOutput") public static Future<TransactionResult> execAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namewATCH
, eXEC
can return a@GloopParameter(name="redisMultiOutput") public static String multi(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool nameOK
.@GloopParameter(name="redisFutureMultiOutput") public static Future<String> multiAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool nameoK
.@GloopParameter(name="redisWatchOutput") public static String watch(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keyOK
.@GloopParameter(name="redisFutureWatchOutput") public static Future<String> watchAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keyoK
.@GloopParameter(name="redisUnwatchOutput") public static String unwatch(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool nameOK
.@GloopParameter(name="redisFutureUnwatchOutput") public static Future<String> unwatchAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool nameoK
.Copyright © 2021. All rights reserved.