ctripcorp/zeus
1
1
Fork 0
mirror of https://github.com/ctripcorp/zeus.git synced 2024-09-20 07:36:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

update lock

Browse source
This commit is contained in:
fanqq 2016-10-24 19:20:55 +08:00
parent 377c7408c4
commit 523e3302a0
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/com/ctrip/zeus/service/message/queue/impl/MessageQueueImpl.java
View file

@ -44,6 +44,7 @@ public class MessageQueueImpl implements MessageQueue {
private Date startTime = new Date();
private Logger logger = LoggerFactory.getLogger(this.getClass());
private FetchThread fetchThread = new FetchThread();
DistLock lock = dbLockFactory.newLock("MessageQueue");
@PostConstruct
private void init() {
@ -84,7 +85,6 @@ public class MessageQueueImpl implements MessageQueue {
public void fetchMessage() throws Exception {
Map<String, List<Message>> res = new HashMap<>();
DistLock lock = dbLockFactory.newLock("MessageQueue");
boolean isLocked = false;
try {
if (isLocked = lock.tryLock()) {