1

全て、

ActiveMQ 5.5 AjaxServletを使用して、JavaScriptを介したActiveMQキュー/トピックリスニングを有効にしています。

このアプローチは、トピックがユーザー名とパスワードで保護されていない場合に正常に機能します。ただし、一度そうなると、トピックサブスクリプションを認証するための適切な構成を見つけるのに苦労しています。

ActiveMQのドキュメントのほとんどはSpringに基づいていますが、この状況では単にAjaxServletを使用しています。したがって、認証パラメーターを指定する手段としてweb.xmlが残されています。おそらく私は間違ったパラメータ名を使用していますか？ActiveMQWebデモはいずれも保護されたトピックに接続しません。

提案を受け付けます！

これが、「ActiveMQ-JS」WARと一緒にデプロイする現在のweb.xmlファイルです。それ自体の?userName=xyz&password=xyz中も指定してみましたが、問題が発生したようです。brokerURL

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
<display-name>activemq-js</display-name>
 <context-param>
    <param-name>org.apache.activemq.brokerURL</param-name>
    <param-value>failover://tcp://127.0.0.1:61616</param-value>
</context-param>
<context-param>
    <param-name>org.apache.activemq.userName</param-name>
    <param-value>username_to_topic</param-value>
</context-param>
<context-param>
    <param-name>org.apache.activemq.password</param-name>
    <param-value>password_to_topic</param-value>
</context-param>
<context-param>
    <param-name>org.apache.activemq.embeddedBroker</param-name>
    <param-value>false</param-value>
</context-param>
<servlet>
<servlet-name>AjaxServlet</servlet-name>
<servlet-class>org.apache.activemq.web.AjaxServlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>AjaxServlet</servlet-name>
<url-pattern>/amq/*</url-pattern>
</servlet-mapping>
<filter>
  <filter-name>session</filter-name>
  <filter-class>org.eclipse.jetty.continuation.ContinuationFilter</filter-class>
</filter>
<filter-mapping>
<filter-name>session</filter-name>
  <url-pattern>/*</url-pattern>
</filter-mapping>
</web-app>
4

1 に答える 1

0

AjaxServlet を拡張し、ユーザー名とパスワードを変更するカスタム ajax サーブレットを作成します。

  public class MyAjaxServlet extends AjaxServlet{

       protected AjaxWebClient getAjaxWebClient( HttpServletRequest request ) {
           AjaxWebClient client = super.getAjaxWebClient(request);
           client.setUsername("test");
           client.setPassword("test");
           return client;
       }

}

カスタム ajax サーブレットで web.xml を更新します。

<servlet>
     <servlet-name>MyAjaxServlet</servlet-name>
     <servlet-class>com.example.esb.web.MyAjaxServlet</servlet-class>
     <init-param>
        <param-name>maximumReadTimeout</param-name>
        <param-value>120000</param-value>
     </init-param>
    <load-on-startup>1</load-on-startup>
     <async-supported>true</async-supported>
 </servlet>
 <servlet-mapping>
   <servlet-name>MyAjaxServlet</servlet-name>
   <url-pattern>/amq/*</url-pattern>
 </servlet-mapping>
于 2013-04-16T07:46:57.230 に答える