@Service public class RabbitmqProducerServiceImpl extends Object implements RabbitmqProducerService
构造器和说明 |
---|
RabbitmqProducerServiceImpl() |
public <T> void sendMsg(Map<String,Object> headers, T message, String messageId, String exchangeName, String routingKey)
RabbitmqProducerService
sendMsg
在接口中 RabbitmqProducerService
headers
- 自定义消息头message
- 消息体messageId
- 消息ID,能够唯一标识消息,消息不可达的时候触发ConfirmCallback回调方法时可以获取该值,进行对应的错误处理exchangeName
- 交换机名routingKey
- 路由KEY