Maven+Spring+ActiveMQ整合

package cn.epaylinks.mq.controller; import javax.annotation.Resource; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import cn.epaylinks.mq.producer.QueueSender; import cn.epaylinks.mq.producer.TopicSender; @Controller @RequestMapping("/activemq") public class ActiveMqController { @Resource QueueSender queueSender; @Resource TopicSender topicSender; /** * 发送消息到队列 * Queue队列：仅有一个订阅者会收到消息，消息一旦被处理就不会存在队列中 * @param message * @return String */ @ResponseBody @RequestMapping("queueSender") public String queueSender(@RequestParam("message")String message) { String opt = ""; try { queueSender.send("queueMessage", message); opt = "suc"; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); opt = e.getCause().toString(); } return opt; } /** * 发送消息到主题 * Topic主题 ：放入一个消息，所有订阅者都会收到 * 这个是主题目的地是一对多的 * @param message * @return String */ @ResponseBody @RequestMapping("topicSender") public String topicSender(@RequestParam("message")String message) { String opt = ""; try { topicSender.send("topicMessage", message); opt = "suc"; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); opt = e.getCause().toString(); } return opt; } }