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>< tomee> </br>
+ < Container id="wmq" type="MESSAGE"><br>
+ ResourceAdapter=wmqRA
+ MessageListenerInterface=javax.jms.MessageListener
+ ActivationSpecClass=com.ibm.mq.connector.inbound.ActivationSpecImpl
+</br>
+ < /Container></p>
+
+<p>< 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>
+ < /Resource></p>
+
+<p>< 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>< 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>
+ < /Resource></p>
+
+<p>< 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>
+ < /Resource></p>
+
+<p>< 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>< 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>< /tomee> </p>
+
+<ol>
+<li>in web.xml add the below to access resources</br>
+< resource-ref> </br>
+ < res-ref-name>myqcf< /res-ref-name> </br>
+< res-type>javax.jms.ConnectionFactory < /res-type></br>
+< res-auth>Container</res-auth>< /br>
+< res-sharing-scope>Shareable< /res-sharing-scope></br>
+< mapped-name>qcf< /mapped-name></br>
+< /resource-ref></p>
+
+<p>< resource-env-ref></br>
+< resource-env-ref-name>myqueue< /resource-env-ref-name></br>
+< resource-env-ref-type>javax.jms.Queue< /resource-env-ref-type></br>
+< mapped-name>queue< /mapped-name></br>
+< /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>