原文地址:
http://activemq.apache.org/setting-up-activemq-with-tomcat-559.html
生成文件 <webapp-root>/META-INF/context.xml. 以下是样例:
<Context antiJARLocking="true">
<Resource
name="jms/ConnectionFactory"
auth="Container"
type="org.apache.activemq.ActiveMQConnectionFactory"
description="JMS Connection Factory"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
brokerURL="tcp://localhost:61616"
brokerName="LocalActiveMQBroker"
useEmbeddedBroker="false"/>
<Resource name="jms/topic/MyTopic"
auth="Container"
type="org.apache.activemq.command.ActiveMQTopic"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
physicalName="MY.TEST.FOO"/>
<Resource name="jms/queue/MyQueue"
auth="Container"
type="org.apache.activemq.command.ActiveMQQueue"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
physicalName="MY.TEST.FOO.QUEUE"/>
</Context>
上面的配置,在Tomcat内产生了一个JMS的ConectionFactory 和Topic 的JNDI上下文。
下面是一段Java样例代码,它像一个名为MY.TEST.FOO 的主题发布一段文本信息:
try {
InitialContext initCtx = new InitialContext();
Context envContext = (Context) initCtx.lookup("java:comp/env");
ConnectionFactory connectionFactory = (ConnectionFactory) envContext.lookup("jms/ConnectionFactory");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer((Destination) envContext.lookup("jms/topic/MyTopic"));
Message testMessage = session.createMessage();
testMessage.setStringProperty("testKey", "testValue");
producer.send(testMessage);
} catch (NamingException e) {
// TODO handle exception
} catch (JMSException e) {
// TODO handle exception
}
分享到:
相关推荐
Apache ActiveMQ是Apache软件基金会的一个开源项目,是一个基于消息的通信中间件。ActiveMQ是JMS的一个具体实现,支持JMS的两种消息模型。ActiveMQ使用AMQP协议集成多平台应用,使用STOMP协议通过websockets在Web...
apache-activemq-5.16.6-bin.zip
为了有助于使用Apache ActiveMQ 5,你也许希望从Version 5 Getting Started手册或Configuring Version 5 Transports开始。除此之外,下面还有一份手册列表: Configure version 5 Brokers(版本5代理的配置) ...
apache-activemq-5.16.5,启动要求jdk版本8+
activemq 5.15源码包
ActiveMQ讲义.pptActiveMQ讲义.pptActiveMQ讲义.ppt
activemq-5.15.15 JDBC持久化mysql8.0+的activemq.xml
activemq, Apache ActiveMQ镜像 欢迎来到 Apache ActiveMQis是一个高性能的Apache 2.0许可以消息代理和 JMS 1.1实现。正在启动要帮助你入门,请尝试以下链接:入门http://activemq.apache.org/version-
1、介绍ActiveMQ5.x消息队列基础特性和本地快速安装 2、SpringBoot2.x整合ActiveMQ实战之点对点消息
factory="org.apache.activemq.jndi.JNDIReferenceFactory" brokerURL="vm://shirdrnUrl" brokerName="MyActiveMQBroker"/> auth="Container" type="org.apache.activemq.command.ActiveMQQueue" ...
使用ActiveMQ示例.pdf
NULL 博文链接:https://baobeituping.iteye.com/blog/407104
ActiveMq 消息队列 面试消息队列
activemq-all.5.14jar包,亲测可用!!
1.解压 tar -zxvf apache-activemq-5.15.12-bin.tar.gz 2.进入bin目录 ...cd /apache-activemq-5.15.12/bin ...3.运行,没有配置环境变量只能在bin目录下...5.activemq的后台默认端口是61616,前台访问端口是8161
ActiveMQ介绍.zip
ActiveMQ与Tomcat整合教程.docx
apache-activemq-5.16.0.zip