java.lang.Object
- io.toro.martini.redis.RedisBaseMethods
- - io.toro.martini.redis.RedisTransactionalMethods

public class RedisTransactionalMethods
extends io.toro.martini.redis.RedisBaseMethods

Methods for Transactions.

Constructor Summary

Constructors
Constructor Description

RedisTransactionalMethods(io.toro.martini.database.DataSourceManager dataSourceManager)

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	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.

Methods inherited from class io.toro.martini.redis.RedisBaseMethods
getDataSourceManager, getRedisConnection, getRedisConnection

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedisTransactionalMethods

@Autowired
RedisTransactionalMethods(io.toro.martini.database.DataSourceManager dataSourceManager)

Method Detail

discard

@GloopParameter(name="redisDiscardOutput")
public static String discard(@GloopParameter(allowNull=false)
                             String connectionName,
                             GloopExecutionContext context)

Discard all commands issued after MULTI.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply always OK.

discardAsync

@GloopParameter(name="redisFutureDiscardOutput")
public static Future<String> discardAsync(@GloopParameter(allowNull=false)
                                          String connectionName,
                                          GloopExecutionContext context)

Asynchronously discard all commands issued after mULTI.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply always oK.

exec

@GloopParameter(name="redisExecOutput")
public static TransactionResult exec(@GloopParameter(allowNull=false)
                                     String connectionName,
                                     GloopExecutionContext context)

Execute all commands issued after MULTI.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: List<Object> array-reply each element being the reply to each of the commands in the atomic transaction. When using WATCH, EXEC can return a

execAsync

@GloopParameter(name="redisFutureExecOutput")
public static Future<TransactionResult> execAsync(@GloopParameter(allowNull=false)
                                                  String connectionName,
                                                  GloopExecutionContext context)

Asynchronously execute all commands issued after mULTI.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: list<Object> array-reply each element being the reply to each of the commands in the atomic transaction. when using wATCH, eXEC can return a

multi

@GloopParameter(name="redisMultiOutput")
public static String multi(@GloopParameter(allowNull=false)
                           String connectionName,
                           GloopExecutionContext context)

Mark the start of a transaction block.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply always OK.

multiAsync

@GloopParameter(name="redisFutureMultiOutput")
public static Future<String> multiAsync(@GloopParameter(allowNull=false)
                                        String connectionName,
                                        GloopExecutionContext context)

Asynchronously mark the start of a transaction block.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply always oK.

watch

@GloopParameter(name="redisWatchOutput")
public static String watch(@GloopParameter(allowNull=false)
                           String connectionName,
                           GloopExecutionContext context,
                           @GloopParameter(allowNull=false)
                           Object... keys)

Watch the given keys to determine execution of the MULTI/EXEC block.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; keys - the key
Returns:: String simple-string-reply always OK.

watchAsync

@GloopParameter(name="redisFutureWatchOutput")
public static Future<String> watchAsync(@GloopParameter(allowNull=false)
                                        String connectionName,
                                        GloopExecutionContext context,
                                        @GloopParameter(allowNull=false)
                                        Object... keys)

Asynchronously watch the given keys to determine execution of the mULTI/EXEC block.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; keys - the key
Returns:: string simple-string-reply always oK.

unwatch

@GloopParameter(name="redisUnwatchOutput")
public static String unwatch(@GloopParameter(allowNull=false)
                             String connectionName,
                             GloopExecutionContext context)

Forget about all watched keys.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply always OK.

unwatchAsync

@GloopParameter(name="redisFutureUnwatchOutput")
public static Future<String> unwatchAsync(@GloopParameter(allowNull=false)
                                          String connectionName,
                                          GloopExecutionContext context)

Asynchronously forget about all watched keys.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply always oK.

Class RedisTransactionalMethods

Constructor Summary