|
@@ -334,7 +334,7 @@ public class RabbitMqListener {
|
|
// 获取缓存锁,防止重复消费
|
|
// 获取缓存锁,防止重复消费
|
|
Long building = redisUtil.incr(key, 1);
|
|
Long building = redisUtil.incr(key, 1);
|
|
buildLogService.save(buildLog);
|
|
buildLogService.save(buildLog);
|
|
- if (building.compareTo(1L) != 0) {
|
|
|
|
|
|
+ if (building.equals(1L)) {
|
|
log.error("服务:{},重复构建:{}",SysConstants.hostName,buildLog.getSceneNum());
|
|
log.error("服务:{},重复构建:{}",SysConstants.hostName,buildLog.getSceneNum());
|
|
throw new BuildException(ModelingBuildStatus.REPEAT);
|
|
throw new BuildException(ModelingBuildStatus.REPEAT);
|
|
}else{
|
|
}else{
|