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:34:28 UTC
svn commit: r841641 - in /websites/staging/openejb/trunk: cgi-bin/ content/
content/tomee-and-webspheremq.html
Author: buildbot
Date: Tue Dec 11 07:34:27 2012
New Revision: 841641
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:34:27 2012
@@ -1 +1 @@
-1420016
+1420020
Propchange: websites/staging/openejb/trunk/content/
------------------------------------------------------------------------------
--- cms:source-revision (original)
+++ cms:source-revision Tue Dec 11 07:34:27 2012
@@ -1 +1 @@
-1420016
+1420020
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:34:27 2012
@@ -147,120 +147,122 @@
</h1>
</div>
-<p><strong>Steps to integrate TomEE with Websphere MQ</strong> <br></p>
+<p><strong>Steps to integrate TomEE with Websphere MQ</strong> </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>
+<pre>
+ <tomee>
+ <Container id="wmq" type="MESSAGE">
ResourceAdapter=wmqRA
MessageListenerInterface=javax.jms.MessageListener
ActivationSpecClass=com.ibm.mq.connector.inbound.ActivationSpecImpl
-</br>
- < /Container></p>
+ </Container>
-<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>
+ <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>
+
+ <Resource **id="qcf"** type="javax.jms.ConnectionFactory" class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl">
+ TransactionSupport=none
+ ResourceAdapter=wmqRA
+ HostName=10.a.b.c
+ Port=1414
+ QueueManager=QM_TIERL
+ Channel=SYSTEM.ADMIN.SVRCONN
+ TransportType=Client
+ UserName=xyz
+ Password=*****
+ </Resource>
+
+ <Resource id="wmq-javax.jms.QueueConnectionFactory" type="javax.jms.QueueConnectionFactory" class-name="com.ibm.mq.connector.outbound.ManagedQueueConnectionFactoryImpl">
+ TransactionSupport=xa
+ ResourceAdapter=wmqRA
+ </Resource>
+
+ <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"** type="javax.jms.Queue"
+class-name="com.ibm.mq.connector.outbound.MQQueueProxy">
+ arbitraryProperties
+ baseQueueManagerName
+ baseQueueName
+ CCSID=1208
+ encoding=NATIVE
+ expiry=APP
+ failIfQuiesce=true
+ persistence=APP
+ priority=APP
+ readAheadClosePolicy=ALL
+ targetClient=JMS
+ </Resource>
+
+ <Resource id="wmq-javax.jms.Topic" type="javax.jms.Topic" class-name="com.ibm.mq.connector.outbound.MQTopicProxy">
+ arbitraryProperties
+ baseTopicName
+ brokerCCDurSubQueue=SYSTEM.JMS.D.CC.SUBSCRIBER.QUEUE
+ brokerDurSubQueue=SYSTEM.JMS.D.SUBSCRIBER.QUEUE
+ brokerPubQueue
+ brokerPubQueueManager
+ brokerVersion=1
+ CCSID=1208
+ encoding=NATIVE
+ expiry=APP
+ failIfQuiesce=true
+ persistence=APP
+ priority=APP
+ readAheadClosePolicy=ALL
+ targetClient=JMS
+ </Resource>
+
+ </tomee>
+
+3. In web.xml add the below to access resources
+ <resource-ref>
+ <res-ref-name>myqcf< /res-ref-name>
+ <res-type>javax.jms.ConnectionFactory < /res-type>
+ <res-auth>Container</res-auth>< /br>
+ <res-sharing-scope>Shareable< /res-sharing-scope>
+ <mapped-name>qcf< /mapped-name>
+ </resource-ref>
+
+ <resource-env-ref>
+ <resource-env-ref-name>myqueue< /resource-env-ref-name>
+ <resource-env-ref-type>javax.jms.Queue< /resource-env-ref-type>
+ <mapped-name>queue< /mapped-name>
+ </resource-env-ref>
+</pre>
+
+<p><strong>Code:</strong></p>
+
+<pre>
+ @Resource(name = "qcf")
+ private ConnectionFactory connectionFactory;
+ @Resource(name = "queue")
+ private Queue queue;
+ Connection connection = connectionFactory.createConnection();
+ Session session = connection.createSession(false, QueueSession.AUTO_ACKNOWLEDGE);
+ MessageProducer producer = session.createProducer(queue);
+ TextMessage message = session.createTextMessage();
+ message.setText("Test Message");
+ connection.start();
+ producer.send(message);
+ session.close();
+ connection.close();
+</pre>