我是activeMQ的新手。我有一些 javascript 连接到 amq 以获取/放置消息:
function init()
{
//AMQ message handler
amq.init({
uri: amqURI,
logging: true,
timeout: amqTimeout,
clientId:amqClientID
});
amq.addListener(amqName, amqTopic, amqHandler);
}
function amqHandler(message)
{
alert("message");
}
function amqSend(content)
{
amq.sendMessage(amqTopic, content);
}
如果网页与队列在同一台机器上提供服务(即在 uri 中使用 localhost:port/amq 或 machinename:port/amq),则此方法工作正常 - 但是连接到另一台机器上的队列只会让我超时。
我已经设置 jetty.xml 包括:
<bean id="Connector" class="org.eclipse.jetty.server.nio.SelectChannelConnector">
<property name="host" value="0.0.0.0"/>
<property name="port" value="8161" />
</bean>
和 web.xml:
<servlet-mapping>
<servlet-name>AjaxServlet</servlet-name>
<url-pattern>/amq/*</url-pattern>
</servlet-mapping>
我什至尝试添加到 activemq.xml:
<transportConnector name="websocket" uri="ws://0.0.0.0:61614"/>
<transportConnector name="nio" uri="nio://0.0.0.0:61616"/>
但是仍然没有运气连接到远程activeMQ。
谢谢!