|
@@ -1505,9 +1505,9 @@ public class Cache {
|
|
|
* @param tx lambda 提供 Transaction 对象,使用该对象对 redis 的操作产生的命令集合将成为原子操作
|
|
* @param tx lambda 提供 Transaction 对象,使用该对象对 redis 的操作产生的命令集合将成为原子操作
|
|
|
*/
|
|
*/
|
|
|
public List<Object> tx(String watchKeys, F10<Transaction> tx) {
|
|
public List<Object> tx(String watchKeys, F10<Transaction> tx) {
|
|
|
- Jedis jedis = getJedis();
|
|
|
|
|
boolean watched = false;
|
|
boolean watched = false;
|
|
|
Transaction transaction = null;
|
|
Transaction transaction = null;
|
|
|
|
|
+ Jedis jedis = getJedis();
|
|
|
try {
|
|
try {
|
|
|
// 多个 watchKey 使用逗号分隔
|
|
// 多个 watchKey 使用逗号分隔
|
|
|
if (StrKit.notBlank(watchKeys)) {
|
|
if (StrKit.notBlank(watchKeys)) {
|
|
@@ -1560,9 +1560,9 @@ public class Cache {
|
|
|
scanParams.count(count);
|
|
scanParams.count(count);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- Jedis jedis = getJedis();
|
|
|
|
|
Boolean continueScan;
|
|
Boolean continueScan;
|
|
|
ScanResult<String> scanResult;
|
|
ScanResult<String> scanResult;
|
|
|
|
|
+ Jedis jedis = getJedis();
|
|
|
try {
|
|
try {
|
|
|
do {
|
|
do {
|
|
|
scanResult = jedis.scan(cursorStr, scanParams);
|
|
scanResult = jedis.scan(cursorStr, scanParams);
|