activemq的高级特性之嵌入式activemq
1:编写activeMQ服务
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.jmx.ManagementContext; /** * 编写activemq的服务 */ public class EmbedMQ { public static void main(String[] args) throws Exception { BrokerService brokerService = new BrokerService(); brokerService.setBrokerName("EmbedMQ"); brokerService.addConnector("tcp://localhost:62000"); brokerService.setManagementContext(new ManagementContext()); brokerService.start(); } }