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

Skip to content

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

channel.xxxx(true->false)

parent 91cffeba
Show whitespace changes
Inline Side-by-side
Showing with 14 additions and 14 deletions
liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerProcessor.java
View file @ 1243fa9d
...@@ -47,12 +47,12 @@ public class ConsumerProcessor { ...@@ -47,12 +47,12 @@ public class ConsumerProcessor {
if (rstBatchSqls) { if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else { } else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("error:consumer sql:{}", JsonUtils.toJson(sqlMessage), e); log.error("error:consumer sql:{}", JsonUtils.toJson(sqlMessage), e);
try { try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} catch (IOException ioException) { } catch (IOException ioException) {
log.error("error:consumer sql:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException); log.error("error:consumer sql:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
} }
...@@ -71,12 +71,12 @@ public class ConsumerProcessor { ...@@ -71,12 +71,12 @@ public class ConsumerProcessor {
if (rstBatchSqls) { if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else { } else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e); log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try { try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} catch (IOException ioException) { } catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException); log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
} }
...@@ -97,12 +97,12 @@ public class ConsumerProcessor { ...@@ -97,12 +97,12 @@ public class ConsumerProcessor {
if (rstBatchSqls) { if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else { } else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e); log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try { try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} catch (IOException ioException) { } catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException); log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
} }
...@@ -123,12 +123,12 @@ public class ConsumerProcessor { ...@@ -123,12 +123,12 @@ public class ConsumerProcessor {
if (rstBatchSqls) { if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else { } else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e); log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try { try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} catch (IOException ioException) { } catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException); log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
} }
...@@ -149,12 +149,12 @@ public class ConsumerProcessor { ...@@ -149,12 +149,12 @@ public class ConsumerProcessor {
if (rstBatchSqls) { if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else { } else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e); log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try { try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} catch (IOException ioException) { } catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException); log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
} }
...@@ -175,12 +175,12 @@ public class ConsumerProcessor { ...@@ -175,12 +175,12 @@ public class ConsumerProcessor {
if (rstBatchSqls) { if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else { } else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e); log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try { try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} catch (IOException ioException) { } catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException); log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), ioException);
} }
...@@ -201,12 +201,12 @@ public class ConsumerProcessor { ...@@ -201,12 +201,12 @@ public class ConsumerProcessor {
if (rstBatchSqls) { if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
} else { } else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e); log.error("error:consumer sql2:{}", JsonUtils.toJson(sqlMessage), e);
try { try {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false); channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
} catch (IOException ioException) { } catch (IOException ioException) {
log.error("error:consumer sql2:basicReject.msg.tag:{}", msg.getMessageProperties().getDeliveryTag(), 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