我目前已经配置了我的tomcat context.xml
这样地:
<Resource name="jms/ConnectionFactory" auth="Container" type="org.apache.activemq.ActiveMQConnectionFactory" description="JMS Connection Factory" factory="org.apache.activemq.jndi.JNDIReferenceFactory" brokerURL="tcp://MY_LOCALHOST_URL:7270" brokerName="LocalActiveMQBroker" useEmbeddedBroker="false"/>
<Resource name="AppJms-HVDIVD17CA50359" auth="Container" type="org.apache.activemq.ActiveMQConnectionFactory" factory="org.apache.activemq.jndi.JNDIReferenceFactory" physicalName="APP.QUEUE" />
我有我的 activemq.xml
:
<transportConnectors>
<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="appjms" uri="tcp://MY_LOCALHOST_URL:7270?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
我在java代码中启动jms,如下所示:
public void createMessageSubscriberJms(String host, int port, String jmsDestination) throws JMSException, UnknownHostException {
String hostname = InetAddress.getLocalHost().getCanonicalHostName();
String providerEndpoints = "tcp://" + hostname + ":" + port + "?wireFormat.maxInactivityDuration=7200000";
// Set the trusted packages/classes to move back and forth on the ActiveMQ JMS service.
ArrayList<String> trustedClasses = new ArrayList<String>();
trustedClasses.add("com.gtt.common.shared.GTCMessage");
// Obtain the factory
ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
activeMQConnectionFactory.setBrokerURL(providerEndpoints);
// Add the trusted packages/classes to the ActiveMQ consumer.
//activeMQConnectionFactory.setTrustedPackages(trustedClasses);
activeMQConnectionFactory.setTrustAllPackages(true);
//Create the connection
setQueueConnection(activeMQConnectionFactory.createQueueConnection());
getQueueConnection().setClientID(this.getName());
// Make a session
setSession(getQueueConnection().createQueueSession(false, Session.AUTO_ACKNOWLEDGE));
getSession().createQueue(jmsDestination);
// Create the destination
Destination destination = getSession().createQueue(jmsDestination);
String selector = "JMSCorrelationID = '" + getActionRequest().getOriginId() + "_" + getActionRequest().getRequestId() + "'" ;
setConsumer(getSession().createConsumer(destination, selector));
getConsumer().setMessageListener(new DefaultMessageListener(this));
// Start ...
// We'll need a message store now
gtcMessages = new GTCMessageQueue<GTCMessage>();
getQueueConnection().start();
}
但当我启动tomcat并调用该方法时,会出现以下错误:
Name [AppJms-HVDIVD17CA50359] is not bound in this Context. Unable to find [AppJms-HVDIVD17CA50359].
你能告诉我我做错了什么吗?我确信,当我使用旧版本的tomcat和activemq时,同样的配置也能工作。
目前我使用的是tomcat9.0.45和activemq5.16.1。
1条答案
按热度按时间koaltpgm1#
你对
AppJms-HVDIVD17CA50359
我觉得有点奇怪:看起来您正在定义一个jms队列,因为
physicalName
属性为APP.QUEUE
. 然而type
是org.apache.activemq.ActiveMQConnectionFactory
哪个是正确的type
对于jms连接工厂,而不是队列。此外org.apache.activemq.ActiveMQConnectionFactory
类没有physicalName
属性。我觉得你应该用org.apache.activemq.command.ActiveMQQueue
来这里是为了type
,例如:值得注意的是,您似乎没有使用
AppJms-HVDIVD17CA50359
或者jms/ConnectionFactory
在这个代码里。我没有看到任何使用这些名称的jndi查找。因此,您可以简单地从应用程序中删除这些资源定义context.xml
(假设应用程序中没有其他程序使用它们),这也可能解决错误。也就是说,我鼓励您使用这些资源,因为这将使将来更新应用程序更加容易,因为如果您需要更改连接工厂或队列配置,那么您只需要修改
context.xml
而不是应用程序的代码。这是在tomcat这样的服务器上运行应用程序的主要好处之一。