如何将 websphere mq 7 队列映射到 EJB 3 目的地名称

Question

我需要将 WebSphere MQ7 队列（例如队列管理器 QMA 中的 queA）映射到 EJB3 MDB。

我使用
创建了 MQ 队列管理器和队列 crtmqm QMA 并使用 strmqm MQA 启动它
然后我写了一个文件文件名 QMA.conf 并包含
定义 QLOCAL ('queA')
将其排列并运行命令
runmqsc QMA runmqsc QMA runmqsc QMA QMA.conf
然后我跑
strmqcsv MQA &
runmqlsr -m QMA -t TCP &
所有这些步骤均以 mqm 登录用户身份完成。

然后我跟着 http://community.jboss.org/wiki/JBossEAP5IntegrationwithWebSphereMQ 链接并配置 RAR 到 jboss 5.1。当我运行测试连接时也成功了。

我在那里包含

* channel - SYSTEM.DEF.SVRCONN
* hostName - localhost
* port - 1414
* queueManager - ExampleQM
* transportType - CLIENT

并在我的 MDB 中包含

@MessageDriven( name="WMQMDBTest",
        activationConfig = 
        { 
            @ActivationConfigProperty(propertyName="messagingType",propertyValue="javax.jms.MessageListener"),
            @ActivationConfigProperty(propertyName = "destinationType",propertyValue = "javax.jms.Queue"),
            @ActivationConfigProperty(propertyName = "destination", propertyValue = "queA"),
            @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "true"),
            @ActivationConfigProperty(propertyName = "channel", propertyValue = "SYSTEM.DEF.SVRCONN"),
            @ActivationConfigProperty(propertyName = "hostName", propertyValue = "localhost"),
            @ActivationConfigProperty(propertyName = "queueManager", propertyValue = "QMA"),
            @ActivationConfigProperty(propertyName = "port", propertyValue = "1414"),
            @ActivationConfigProperty(propertyName = "transportType", propertyValue = "CLIENT"),
            @ActivationConfigProperty(propertyName = "username", propertyValue = "mqm"),
            @ActivationConfigProperty(propertyName = "password", propertyValue = "password")
        }) 
@TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
@ResourceAdapter(value = "wmq.jmsra.rar")

当我尝试部署 bean 时它说

DEPLOYMENTS IN ERROR:
  Deployment "jboss.j2ee:ear=integration-1.0-SNAPSHOT.ear,jar=business-logic-1.0-SNAPSHOT.jar,  
  name=WMQMDBTest,service=EJB3" is in error due to the following reason(s): 
javax.naming.NameNotFoundException: queA not bound

Answer 1

你写过

 @ActivationConfigProperty(propertyName = "destination", propertyValue = "queA"),
        @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "true"),

useJNDI 属性暗示“queA”是将 JMS 队列绑定到 JNDI 命名空间的名称 - 这并不直接对应于您在此处定义的队列

定义 QLOCAL ('queA')

如果您希望它引用队列管理器上的物理 WMQ 队列，那么您需要将 useJNDI 属性设置为 false，在这种情况下，目标指定队列管理器上的队列名称，而不是 JNDI姓名。另一方面，如果您确实想使用目的地的 JNDI 查找，那么您需要确保指定的目的地名称与 -ds.xml 文件中的队列定义匹配，例如

 @ActivationConfigProperty(propertyName = "目的地", propertyValue = "jms/request")

将对应于

<mbean code="org.jboss.resource.deployment.AdminObject" name="jca.wmq:name=request_queue">
    <attribute name="JNDIName">jms/request</attribute>
    <depends optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='wmq.jmsra.rar'</depends>
    <attribute name="Type">javax.jms.Queue</attribute>
    <attribute name="Properties">
        baseQueueManagerName=QMA            
        baseQueueName=queA
    </attribute>
</mbean>

注释 mbean 的 JNDIName 属性对应于目标名称