package com.java110.order.mq;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.jms.core.JmsMessagingTemplate;
|
import org.springframework.stereotype.Component;
|
|
import javax.jms.Queue;
|
import javax.jms.Topic;
|
|
|
/**
|
* 作废订单信息
|
*
|
* Created by wuxw on 2017/4/17.
|
*/
|
@Component
|
public class DeleteOrderInfoProducer {
|
|
@Autowired
|
private JmsMessagingTemplate jmsMessagingTemplate;
|
|
@Autowired
|
private Topic deleteOrderTopic;
|
|
|
/**
|
* 发布消息
|
* @param msg
|
*/
|
public void send(String msg) {
|
this.jmsMessagingTemplate.convertAndSend(deleteOrderTopic, msg);
|
}
|
}
|
