feat(测试): activemq topic消息发送测试
This commit is contained in:
parent
2c6af40107
commit
7ed6d06830
@ -0,0 +1,31 @@
|
||||
package com.foreverwin.nlv.print.controller;
|
||||
|
||||
import com.foreverwin.mom.common.core.util.R;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.apache.activemq.command.ActiveMQTopic;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.jms.core.JmsMessagingTemplate;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import javax.jms.Destination;
|
||||
|
||||
@RestController
|
||||
@RequiredArgsConstructor
|
||||
@RequestMapping("/topic-send-test" )
|
||||
public class TopicSendTestController {
|
||||
|
||||
@Autowired
|
||||
@Qualifier("printActivemqTemplate")
|
||||
private JmsMessagingTemplate jmsTemplate;
|
||||
|
||||
|
||||
@GetMapping("/send" )
|
||||
public R send(String topicName, String message) {
|
||||
Destination destination = new ActiveMQTopic(topicName);
|
||||
jmsTemplate.convertAndSend(destination, message);
|
||||
return R.ok();
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user