2014-12-02 73 views
0

我有一个项目,我试图在TomEE 1.7中部署EJB 2消息驱动Bean(MDB)。我需要这些MDB来连接和读取来自两个Websphere MQ的消息。但是我无法在Internet上找到足够的文档。无论从任何我可以从Websphere MQ configuration in JBoss一起分析我创建了以下使用EJB 2 MDB在TomEE中配置入站Websphere MQ

<Resource id="wmqRA" type="com.ibm.mq.connector.ResourceAdapterImpl" class-name="com.ibm.mq.connector.ResourceAdapterImpl"> 
    connectionConcurrency=5 
    maxConnections=10 
    logWriterEnabled=true 
    reconnectionRetryCount=5 
    reconnectionRetryInterval=300000 
    traceEnabled=false 
    traceLevel=3 

<Resource id="jms/ABC" type="javax.jms.ConnectionFactory" class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl"> 
    TransactionSupport=none 
    ResourceAdapter=wmqRA 
    HostName=10.190.129.132 
    Port=1414 
    QueueManager=<QueueManagerName> 
    Channel=<ChannelName> 
    TransportType=Client 
    UserName=mqm 
    Password=abc 
    </Resource> 

<Container id="wmq" type="MESSAGE"> 
    ResourceAdapter=wmqRA 
    MessageListenerInterface=javax.jms.MessageListener 
    ActivationSpecClass=com.ibm.mq.connector.inbound.ActivationSpecImpl 
</Container> 

<Resource id="wmq-javax.jms.QueueConnectionFactory" type="javax.jms.QueueConnectionFactory" class-name="com.ibm.mq.connector.outbound.ManagedQueueConnectionFactoryImpl"> 
TransactionSupport=xa 
ResourceAdapter=wmqRA 

<Resource id="wmq-javax.jms.TopicConnectionFactory" type="javax.jms.TopicConnectionFactory" class-name="com.ibm.mq.connector.outbound.ManagedTopicConnectionFactoryImpl"> 
TransactionSupport=xa 
ResourceAdapter=wmqRA 
</Resource> 

<Resource id="queue_id" type="javax.jms.Queue" class-name="com.ibm.mq.connector.outbound.MQQueueProxy"> 
arbitraryProperties 
baseQueueManagerName=<QueueManagerName> 
baseQueueName=<QueueName> 
CCSID=1208 
encoding=NATIVE 
expiry=APP 
failIfQuiesce=true 
persistence=APP 
priority=APP 
readAheadClosePolicy=ALL 
targetClient=JMS 
</Resource>` 

的连接得到建立与队列管理器(通过验证的runmqsc),但当消息被添加到队列时,EJB不会被触发/创建。

任何方向将不胜感激

回答

0

得到了很多试错后的解决方案。看起来我们需要在ejb-jar.xml中为EJB2指定与Tomee一起工作。

使用此

<message-driven> 
     <ejb-name>beanName</ejb-name> 
     <ejb-class>beanClass</ejb-class> 
     <messaging-type>javax.jms.MessageListener</messaging-type> 
     <transaction-type>Bean</transaction-type> 
     <message-destination-type>javax.jms.Queue</message-destination-type> 
     <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>*queueName*</activation-config-property-value> 
      </activation-config-property> 
      <activation-config-property> 
       <activation-config-property-name>channel</activation-config-property-name> 
       <activation-config-property-value>*channelName*</activation-config-property-value> 
      </activation-config-property> 
      <activation-config-property> 
       <activation-config-property-name>hostName</activation-config-property-name> 
       <activation-config-property-value>*hostName*</activation-config-property-value> 
      </activation-config-property> 
      <activation-config-property> 
       <activation-config-property-name>port</activation-config-property-name> 
       <activation-config-property-value>1414</activation-config-property-value> 
      </activation-config-property> 
      <activation-config-property> 
       <activation-config-property-name>queueManager</activation-config-property-name> 
       <activation-config-property-value>*queueManager*</activation-config-property-value> 
      </activation-config-property> 
      <activation-config-property> 
       <activation-config-property-name>transportType</activation-config-property-name> 
       <activation-config-property-value>CLIENT</activation-config-property-value> 
      </activation-config-property> 
      </activation-config>