//package com.smartor.config;
|
//
|
//import lombok.extern.slf4j.Slf4j;
|
//import org.springframework.amqp.core.Message;
|
//import org.springframework.amqp.rabbit.connection.CorrelationData;
|
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
//import org.springframework.beans.factory.annotation.Autowired;
|
//import org.springframework.stereotype.Component;
|
//
|
//import javax.annotation.PostConstruct;
|
//
|
//@Slf4j
|
//@Component
|
//public class RabbitMQAckConfig implements RabbitTemplate.ConfirmCallback,RabbitTemplate.ReturnCallback {
|
//
|
//
|
// @Autowired
|
// private RabbitTemplate rabbitTemplate;
|
//
|
// @PostConstruct
|
// public void init(){
|
// rabbitTemplate.setConfirmCallback(this);
|
// rabbitTemplate.setReturnCallback(this);
|
// }
|
//
|
//
|
// //判断是否到达交换机
|
// @Override
|
// public void confirm(CorrelationData correlationData, boolean ack, String cause) {
|
// if (ack){
|
// log.info("消息到了交换机");
|
// System.out.println("消息到了交换机 -------------");
|
// }else {
|
// log.info("消息没有到达交换机");
|
// System.out.println("消息没有到交换机----------------- ");
|
// }
|
// }
|
//
|
// //判断是否到达队列
|
// @Override
|
// public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
|
// System.out.println("message消息 = " + new String(message.getBody()));
|
// System.out.println("replyCode应答码 = " + replyCode);
|
// System.out.println("replyText描述 = " + replyText);
|
// System.out.println("exchange交换机 = " + exchange);
|
// System.out.println("routingKey路由key = " + routingKey);
|
// }
|
//}
|
