Commit e7851f72 by 周晓航

MQ的可靠性投递优化

parent 102ea6fd
...@@ -7,10 +7,10 @@ import org.springframework.amqp.rabbit.connection.ConnectionFactory; ...@@ -7,10 +7,10 @@ import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.CorrelationData; import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Configurable;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Primary; import org.springframework.context.annotation.Primary;
import org.springframework.context.annotation.Scope; import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct; import javax.annotation.PostConstruct;
...@@ -20,7 +20,7 @@ import javax.annotation.PostConstruct; ...@@ -20,7 +20,7 @@ import javax.annotation.PostConstruct;
* @Date : 2022/8/19 14:40 * @Date : 2022/8/19 14:40
* @description : 消息投递 确认机制 * @description : 消息投递 确认机制
*/ */
@Configurable @Component
@Log4j2 @Log4j2
public class SendMQConfirmCallback { public class SendMQConfirmCallback {
......
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