Skip to content

C
commons
Commit 934e62be authored by 杨锐's avatar 杨锐
Browse files
Options

confirm first message status.

parent a599264b
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 1 deletion
mq-plus-spring-boot-starter/src/main/java/cn/quantgroup/tech/mq/config/MORabbitMQConfiguration.java
View file @ 934e62be
...@@ -62,7 +62,10 @@ public class MORabbitMQConfiguration { ...@@ -62,7 +62,10 @@ public class MORabbitMQConfiguration {
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory); RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> { rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
if (ack) { if (ack) {
koalaRabbitmqMessageMapperV1.updateMsgStatusByUniqueId(correlationData.getId(), Constants.MSG_STATUS_SUCCESS); KoalaRabbitmqMessage koalaRabbitmqMessage = koalaRabbitmqMessageMapperV1.selectByUniqueId(correlationData.getId());
if (koalaRabbitmqMessage.getConsumeCount() == 0) {
koalaRabbitmqMessageMapperV1.updateMsgStatusByUniqueId(correlationData.getId(), Constants.MSG_STATUS_SUCCESS);
}
} }
}); });
rabbitTemplate.setBeforePublishPostProcessors(new CorrelationAwareMessagePostProcessor() { rabbitTemplate.setBeforePublishPostProcessors(new CorrelationAwareMessagePostProcessor() {
......
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