记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 91cffeba authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

channel.xxxx(true->false)

parent 8fdce367
Hide whitespace changes
Inline Side-by-side
Showing with 21 additions and 21 deletions
liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerProcessor.java
View file @ 91cffeba
......@@ -45,14 +45,14 @@ public class ConsumerProcessor {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("consumer sql result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
}
} catch (Exception e) {
log.error("error:consumer sql:{}", JsonUtils.toJson(sqlMessage), e);
try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
} catch (IOException ioException) {
log.error("error:consumer sql:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
}
......@@ -69,14 +69,14 @@ public class ConsumerProcessor {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("consumer sql2 result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
}
} catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
} catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
}
......@@ -95,14 +95,14 @@ public class ConsumerProcessor {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_ORDER_CREATE result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
}
} catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
} catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
}
......@@ -121,14 +121,14 @@ public class ConsumerProcessor {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_ORDER_PAY_AGAIN result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
}
} catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
} catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
}
......@@ -147,14 +147,14 @@ public class ConsumerProcessor {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_ORDER_CLOSE result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
}
} catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
} catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
}
......@@ -173,14 +173,14 @@ public class ConsumerProcessor {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_ORDER_PAY result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
}
} catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
} catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
}
......@@ -199,14 +199,14 @@ public class ConsumerProcessor {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_PERFORMANCE_LACK result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
}
} catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
} catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment