发送消息到队列中
ActiveMQ客户端最小依赖JAR包:
public static void testSend() throws Exception {
ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER/*NULL*/,
ActiveMQConnection.DEFAULT_PASSWORD/*NULL*/, "tcp://localhost:61616");
Connection connection = factory.createConnection();
connection.start();
Session session = connection.createSession(true/*支持事务*/, Session.AUTO_ACKNOWLEDGE);
Destination queue = session.createQueue("test_123");
MessageProducer producer = session.createProducer(queue/*也可以为NULL,则在发送时才指定目标队列*/);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
TextMessage message = session.createTextMessage();
message.setText("你好!!");
message.setJMSPriority(Message.DEFAULT_PRIORITY);
producer.send(message);
session.commit();
session.close();
connection.close();
}
执行上面代码,然后观察Jconsole和webconsole的变化:
附件:ActiveMQ客户端代码
相关推荐
赠送jar包:activemq-protobuf-1.1.jar; 赠送原API文档:activemq-protobuf-1.1-javadoc.jar; 赠送源代码:activemq-protobuf-1.1-sources.jar; 包含翻译后的API文档:activemq-protobuf-1.1-javadoc-API文档-...
activemq-pool-5.8.0-sources.jar
NULL 博文链接:https://sswh.iteye.com/blog/1974131
activemq-cpp-library-3.9.5编译的C++库文件,支持vs2015,vs2017,包括了依赖的库文件和头文件,可以在项目中直接使用。
NULL 博文链接:https://sswh.iteye.com/blog/1974156
赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...
赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...
Apache ActiveMQ是Apache软件基金会的一个开源项目,是一个基于消息的通信中间件。ActiveMQ是JMS的一个具体实现,支持JMS的两种消息模型。ActiveMQ使用AMQP协议集成多平台应用,使用STOMP协议通过websockets在Web...
activemq-all-5.12.0-sources.jar
activemq-jms-pool-5.14.4.jar
赠送jar包:activemq-protobuf-1.1.jar; 赠送原API文档:activemq-protobuf-1.1-javadoc.jar; 赠送源代码:activemq-protobuf-1.1-sources.jar; 包含翻译后的API文档:activemq-protobuf-1.1-javadoc-API文档-...
标签:activemq-web-console-5.8.0-sources.jar,activemq,web,console,5.8.0,sources,jar包下载,依赖包
标签:activemq-web-console-5.2.0-sources.jar,activemq,web,console,5.2.0,sources,jar包下载,依赖包
标签:activemq-web-console-5.2.0-javadoc.jar,activemq,web,console,5.2.0,javadoc,jar包下载,依赖包
标签:activemq-jms-pool-5.10.0-javadoc.jar,activemq,jms,pool,5.10.0,javadoc,jar包下载,依赖包
标签:activemq-kahadb-store-5.10.0-sources.jar,activemq,kahadb,store,5.10.0,sources,jar包下载,依赖包
activemq-web-console的默认使用方式是通过在activemq.xml中导入jetty.xml配置一个jetty server来实现的。其实activemq-web-console完全可以和activemq-broker分开来部署。 activemq-web-console包含3个apps, 1.一...
标签:activemq-jms-pool-5.10.0.jar,activemq,jms,pool,5.10.0,jar包下载,依赖包
activemq-cpp-library-3.9.5-src.zip