3

我正在尝试使用 glassfish 2.1 提供的通用资源适配器在 glassfish 中使用 activemq。我发现了一些包含有用信息的页面，包括http://activemq.apache.org/sjsas-with-genericjmsra.html。

我实际上已经取得了成功，并且能够让 MDB 使用 activemq 作为他们的 JMS 提供程序，但是当我尝试进行一些更复杂的配置时遇到了一个问题。我想设置一个主从配置，这将要求我的客户使用故障转移的 brokerURL:(tcp://broker1:61616,tcp://broker2:61616)。为了做到这一点，我在调用 asadmin 时设置了以下属性create-resource-adapter-config（我必须转义 '=' 和 ':'）：

ConnectionFactoryProperties=brokerURL\=failover\:(tcp\://127.0.0.1\:61616,tcp\://127.0.0.1\:61617)

但是，当我的应用程序启动时，我现在收到了 StringIndexOutOfBoundsException。我怀疑两个 URL 之间的逗号是罪魁祸首，因为这很好用：

brokerURL\=failover\:(tcp\://127.0.0.1\:61616)

只是想知道是否有人以前处理过这个问题。还想知道是否有比使用通用资源适配器更好的方法来与 glassfish 集成。

编辑：我忘了在第二个 tcp 之后转义冒号，但不幸的是，这并没有解决我看到的问题。

4

3 回答 3

3

我最终切换到使用 lib/optional 目录中的 activemq 提供的资源适配器。

如果有人有兴趣，这是我为使其工作而遵循的步骤

asadmin create-resource-adapter-config --property ServerUrl=failover\:(tcp\://localhost\:61616,tcp\://localhost\:61617) activemqra

asadmin deploy --name activemqra <path to activemq-rar-5.4.2.rar>

然后创建资源：

asadmin create-connector-connection-pool --raname --connectiondefinition javax.jms.ConnectionFactory --transactionsupport XATransaction jms/MyQueueFactoryPool

asadmin create-connector-resource --poolname jms/MyQueueFactoryPool jms/MyQueueQFactory

asadmin create-admin-object --raname activemqra --restype javax.jms.Queue --property PhysicalName=MyQueue jms/MyQueue

要连接 mdb，我必须在 sun-ejb-jar.xml 中添加它

<mdb-resource-adapter>
                <resource-adapter-mid>activemqra</resource-adapter-mid>
                <activation-config>
                    <activation-config-property>
                        <activation-config-property-name>DestinationType
                        </activation-config-property-name>
                        <activation-config-property-value>javax.jms.Queue
                        </activation-config-property-value>
                    </activation-config-property>
                    <activation-config-property>
                        <activation-config-property-name>destination
                        </activation-config-property-name>
                        <activation-config-property-value>MyQueue
                        </activation-config-property-value>
                    </activation-config-property>
                </activation-config>
            </mdb-resource-adapter>

要将其连接到 spring JMSTemplate：

<bean id="ConFac" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiName">
            <value>jms/MyQueueQQFactory</value>
        </property>
        <property name="resourceRef">
            <value>true</value>
        </property>
    </bean>
    <bean id="myqueue" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiName">
            <value>jms/MyQueue</value>
        </property>
        <property name="resourceRef">
            <value>true</value>
        </property>
    </bean>
    <bean id="mdbTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="conFac" />
        <property name="defaultDestination" ref="myqueue" />
    </bean>
于 2011-01-18T20:52:55.837 回答
1

这是 genericjmsra 中的一个已知缺陷，请参阅：http: //java.net/jira/browse/GENERICJMSRA-50

在评论中建议在 ObjectBuilder.java 中进行修复。

于 2012-07-04T12:30:44.193 回答
0

我看起来你没有在第二个 uri 中转义冒号。

于 2011-01-17T04:20:19.107 回答