package com.xzx.gc.config;
|
|
import com.xzx.gc.rabbitmq.ConfirmCallBackListener;
|
import com.xzx.gc.rabbitmq.ReturnCallBackListener;
|
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
|
@Configuration
|
public class RabbitConfig {
|
|
@Autowired
|
private ConfirmCallBackListener confirmCallBackListener;
|
|
@Autowired
|
private ReturnCallBackListener returnCallBackListener;
|
|
@Bean
|
RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
|
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
|
rabbitTemplate.setMandatory(true);
|
rabbitTemplate.setConfirmCallback( confirmCallBackListener);
|
rabbitTemplate.setReturnCallback(returnCallBackListener);
|
return rabbitTemplate;
|
}
|
}
|
