Skip to content

Commit 040939d

Browse files
committed
fixed bug.
1 parent 03c8697 commit 040939d

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

txlcn-tm/src/main/java/com/codingapi/txlcn/tm/core/storage/redis/RedisStorage.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -262,7 +262,7 @@ public int acquireOrRefreshMachineId(int machineId, long machineMaxSize, long ti
262262
}
263263
throw new FastStorageException("non can used machine id", FastStorageException.EX_CODE_NON_MACHINE_ID);
264264
}
265-
stringRedisTemplate.opsForValue().set(REDIS_GROUP_PREFIX + machineId, "", timeout, TimeUnit.MILLISECONDS);
265+
stringRedisTemplate.opsForValue().set(REDIS_MACHINE_ID_MAP_PREFIX + machineId, "", timeout, TimeUnit.MILLISECONDS);
266266
return -1;
267267
} finally {
268268
releaseGlobalXLock();

0 commit comments

Comments
 (0)