You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@tomee.apache.org by bu...@apache.org on 2012/12/11 08:22:59 UTC

svn commit: r841638 - in /websites/staging/openejb/trunk: cgi-bin/ content/ content/tomee-and-webspheremq.html

Author: buildbot
Date: Tue Dec 11 07:22:58 2012
New Revision: 841638

Log:
Staging update by buildbot for openejb

Modified:
    websites/staging/openejb/trunk/cgi-bin/   (props changed)
    websites/staging/openejb/trunk/content/   (props changed)
    websites/staging/openejb/trunk/content/tomee-and-webspheremq.html

Propchange: websites/staging/openejb/trunk/cgi-bin/
------------------------------------------------------------------------------
--- cms:source-revision (original)
+++ cms:source-revision Tue Dec 11 07:22:58 2012
@@ -1 +1 @@
-1418209
+1420016

Propchange: websites/staging/openejb/trunk/content/
------------------------------------------------------------------------------
--- cms:source-revision (original)
+++ cms:source-revision Tue Dec 11 07:22:58 2012
@@ -1 +1 @@
-1418209
+1420016

Modified: websites/staging/openejb/trunk/content/tomee-and-webspheremq.html
==============================================================================
--- websites/staging/openejb/trunk/content/tomee-and-webspheremq.html (original)
+++ websites/staging/openejb/trunk/content/tomee-and-webspheremq.html Tue Dec 11 07:22:58 2012
@@ -147,7 +147,120 @@
 </h1>
 </div>
 
+<p><strong>Steps to integrate TomEE with Websphere MQ</strong> <br></p>
 
+<ol>
+<li>Unzip rar file place jars under tomee/lib</li>
+<li>Added the below to conf/tomee.xml</li>
+</ol>
+
+<p>&lt; tomee> </br>
+  &lt; Container id="wmq" type="MESSAGE"><br>
+    ResourceAdapter=wmqRA
+    MessageListenerInterface=javax.jms.MessageListener
+    ActivationSpecClass=com.ibm.mq.connector.inbound.ActivationSpecImpl
+</br>
+  &lt; /Container></p>
+
+<p>&lt; Resource id="wmqRA" type="com.ibm.mq.connector.ResourceAdapterImpl" <br>class-name="com.ibm.mq.connector.ResourceAdapterImpl">
+    <br>connectionConcurrency=5  </br>
+    maxConnections=10 </br>
+    logWriterEnabled=true </br>
+    reconnectionRetryCount=5 </br>
+    reconnectionRetryInterval=300000 </br>
+    traceEnabled=false </br>
+    traceLevel=3 </br>
+  &lt; /Resource></p>
+
+<p>&lt; Resource <strong>id="qcf"</strong> </br> type="javax.jms.ConnectionFactory" class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl">
+    TransactionSupport=none </br>
+    ResourceAdapter=wmqRA </br>
+    HostName=10.a.b.c </br> <br />
+    Port=1414 </br>
+    QueueManager=QM_TIERL</br>
+   Channel=SYSTEM.ADMIN.SVRCONN</br>
+   TransportType=Client</br>
+   UserName=xyz</br>
+   Password=<strong>*</strong></br>
+  </Resource></p>
+
+<p>&lt; Resource id="wmq-javax.jms.QueueConnectionFactory" </br> type="javax.jms.QueueConnectionFactory" class-name="com.ibm.mq.connector.outbound.ManagedQueueConnectionFactoryImpl">
+    TransactionSupport=xa </br>
+    ResourceAdapter=wmqRA </br>
+  &lt; /Resource></p>
+
+<p>&lt; Resource id="wmq-javax.jms.TopicConnectionFactory" </br> type="javax.jms.TopicConnectionFactory" class-name="com.ibm.mq.connector.outbound.ManagedTopicConnectionFactoryImpl">
+    TransactionSupport=xa </br>
+    ResourceAdapter=wmqRA </br>
+  &lt; /Resource></p>
+
+<p>&lt; Resource <strong>id="queue"</strong> type="javax.jms.Queue" </br> 
+class-name="com.ibm.mq.connector.outbound.MQQueueProxy"> </br>
+    arbitraryProperties </br>
+    baseQueueManagerName </br>
+    baseQueueName </br>
+    CCSID=1208 </br>
+    encoding=NATIVE </br>
+    expiry=APP </br>
+    failIfQuiesce=true </br>
+    persistence=APP </br>
+    priority=APP </br>
+    readAheadClosePolicy=ALL </br>
+    targetClient=JMS </br>
+  </Resource></p>
+
+<p>&lt; Resource id="wmq-javax.jms.Topic" type="javax.jms.Topic" class-name="com.ibm.mq.connector.outbound.MQTopicProxy">
+    arbitraryProperties </br>
+    baseTopicName </br>
+    brokerCCDurSubQueue=SYSTEM.JMS.D.CC.SUBSCRIBER.QUEUE </br>
+    brokerDurSubQueue=SYSTEM.JMS.D.SUBSCRIBER.QUEUE </br>
+    brokerPubQueue </br>
+    brokerPubQueueManager </br>
+    brokerVersion=1 </br>
+    CCSID=1208 </br>
+    encoding=NATIVE </br>
+    expiry=APP </br>
+    failIfQuiesce=true </br>
+    persistence=APP </br>
+    priority=APP </br>
+    readAheadClosePolicy=ALL </br>
+    targetClient=JMS </br>
+  </Resource> </br></p>
+
+<p>&lt; /tomee>    </p>
+
+<ol>
+<li>in web.xml add the below to access resources</br>
+&lt; resource-ref> </br>
+ &lt; res-ref-name>myqcf&lt; /res-ref-name> </br>
+&lt; res-type>javax.jms.ConnectionFactory &lt; /res-type></br>
+&lt; res-auth>Container</res-auth>&lt; /br>
+&lt; res-sharing-scope>Shareable&lt; /res-sharing-scope></br>
+&lt; mapped-name>qcf&lt; /mapped-name></br>
+&lt; /resource-ref></p>
+
+<p>&lt; resource-env-ref></br>
+&lt; resource-env-ref-name>myqueue&lt; /resource-env-ref-name></br>
+&lt; resource-env-ref-type>javax.jms.Queue&lt; /resource-env-ref-type></br>
+&lt; mapped-name>queue&lt; /mapped-name></br>
+&lt; /resource-env-ref></br></li>
+</ol>
+
+<p><strong>Java Code: </br></strong></p>
+
+<p>@Resource(name = "qcf") </br>
+private ConnectionFactory connectionFactory; </br>
+@Resource(name = "queue") </br>
+private Queue queue;</br></br>
+Connection connection = connectionFactory.createConnection();</br>
+Session session = connection.createSession(false, QueueSession.AUTO_ACKNOWLEDGE);
+MessageProducer producer = session.createProducer(queue);</br>
+TextMessage message = session.createTextMessage();</br>
+message.setText("Test Message");</br>
+connection.start();</br>
+producer.send(message);</br>
+session.close();</br>
+connection.close();</br></p>