|
|
@ -44,6 +44,7 @@ public class RabbitTemplateConfig {
|
|
|
|
return new RabbitTemplate.ConfirmCallback(){
|
|
|
|
return new RabbitTemplate.ConfirmCallback(){
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
|
|
|
|
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
|
|
|
|
|
|
|
|
System.out.println("confirm:" + Thread.currentThread().getName());
|
|
|
|
if (correlationData == null) return;
|
|
|
|
if (correlationData == null) return;
|
|
|
|
String msgId = correlationData.getId();
|
|
|
|
String msgId = correlationData.getId();
|
|
|
|
if(ack){
|
|
|
|
if(ack){
|
|
|
|