- JMS方式调用
- Queue方式调用
- Topic方式调用
- ReqRsp方式调用
1、TestMsg.java
package com.neohope.ActiveMQ.test.beans;
public class TestMsg implements java.io.Serializable{
private static final long serialVersionUID = 12345678;
public TestMsg(int taskId, String taskInfo, int taskLevel) {
this.taskId = taskId;
this.taskInfo = taskInfo;
this.taskLevel = taskLevel;
}
public int taskId;
public String taskInfo;
public int taskLevel;
}