Skip to content

Commit 230e0a5

Browse files
committed
Manager server info use Set
1 parent 2a44cfb commit 230e0a5

2 files changed

Lines changed: 8 additions & 3 deletions

File tree

tx-client/src/main/java/com/codingapi/tx/client/spi/message/txc/TxcTransactionCleanService.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,6 @@ public TxcTransactionCleanService(TxcService txcService) {
2828
this.txcService = txcService;
2929
}
3030

31-
@Autowired
32-
private TxLogger txLogger;
33-
3431
@Override
3532
public void clear(String groupId, int state, String unitId, String unitType) throws TransactionClearException {
3633
try {

tx-manager/src/main/java/com/codingapi/tx/manager/db/redis/RedisSetManagerStorage.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
import org.springframework.beans.factory.annotation.Value;
88
import org.springframework.data.redis.core.RedisTemplate;
99

10+
import javax.annotation.PostConstruct;
1011
import javax.annotation.PreDestroy;
1112
import java.util.ArrayList;
1213
import java.util.List;
@@ -42,6 +43,13 @@ public void remove(String address) {
4243
redisTemplate.opsForSet().remove(REDIS_PREFIX, address);
4344
}
4445

46+
@PostConstruct
47+
public void init() {
48+
String address = managerConfig.getHost() + ":" + port;
49+
redisTemplate.opsForSet().add(REDIS_PREFIX, address);
50+
log.info("manager add redis finish.");
51+
}
52+
4553
@PreDestroy
4654
public void destroy() {
4755
String address = managerConfig.getHost() + ":" + port;

0 commit comments

Comments
 (0)