更新ActiveMQ示例代码
This commit is contained in:
@@ -11,8 +11,6 @@ import javax.annotation.Resource;
|
|||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
|
||||||
* @author liang
|
|
||||||
* @description controller测试
|
* @description controller测试
|
||||||
*/
|
*/
|
||||||
@Controller
|
@Controller
|
||||||
|
@@ -9,10 +9,7 @@ import javax.jms.MessageListener;
|
|||||||
import javax.jms.TextMessage;
|
import javax.jms.TextMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
|
||||||
* @author liang
|
|
||||||
* @description 队列消息监听器
|
* @description 队列消息监听器
|
||||||
*
|
|
||||||
*/
|
*/
|
||||||
@Component
|
@Component
|
||||||
public class QueueReceiver1 implements MessageListener {
|
public class QueueReceiver1 implements MessageListener {
|
||||||
|
@@ -9,10 +9,7 @@ import javax.jms.MessageListener;
|
|||||||
import javax.jms.TextMessage;
|
import javax.jms.TextMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
|
||||||
* @author liang
|
|
||||||
* @description 队列消息监听器
|
* @description 队列消息监听器
|
||||||
*
|
|
||||||
*/
|
*/
|
||||||
@Component
|
@Component
|
||||||
public class QueueReceiver2 implements MessageListener {
|
public class QueueReceiver2 implements MessageListener {
|
||||||
@@ -25,5 +22,4 @@ public class QueueReceiver2 implements MessageListener {
|
|||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -7,17 +7,12 @@ import javax.jms.Message;
|
|||||||
import javax.jms.MessageListener;
|
import javax.jms.MessageListener;
|
||||||
import javax.jms.TextMessage;
|
import javax.jms.TextMessage;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
|
||||||
* @author liang
|
|
||||||
* @description Topic消息监听器
|
* @description Topic消息监听器
|
||||||
*
|
|
||||||
*/
|
*/
|
||||||
@Component
|
@Component
|
||||||
public class TopicReceiver1 implements MessageListener{
|
public class TopicReceiver1 implements MessageListener{
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onMessage(Message message) {
|
public void onMessage(Message message) {
|
||||||
try {
|
try {
|
||||||
@@ -26,5 +21,4 @@ public class TopicReceiver1 implements MessageListener{
|
|||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
|
@@ -8,15 +8,11 @@ import javax.jms.MessageListener;
|
|||||||
import javax.jms.TextMessage;
|
import javax.jms.TextMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
|
||||||
* @author liang
|
|
||||||
* @description Topic消息监听器
|
* @description Topic消息监听器
|
||||||
*
|
|
||||||
*/
|
*/
|
||||||
@Component
|
@Component
|
||||||
public class TopicReceiver2 implements MessageListener{
|
public class TopicReceiver2 implements MessageListener{
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onMessage(Message message) {
|
public void onMessage(Message message) {
|
||||||
try {
|
try {
|
||||||
|
Reference in New Issue
Block a user