Author: ataylor Date: 2009-08-21 09:25:26 -0400 (Fri, 21 Aug 2009) New Revision: 7866 Added: trunk/examples/javaee/mdb-tx-send/src/org/hornetq/ trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/ trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/ trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/MDBMessageSendTxClientExample.java trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/server/ trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/server/MDBMessageSendTxExample.java Log: readded mdb tx send example Added: trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/MDBMessageSendTxClientExample.java =================================================================== --- trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/MDBMessageSendTxClientExample.java (rev 0) +++ trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/MDBMessageSendTxClientExample.java 2009-08-21 13:25:26 UTC (rev 7866) @@ -0,0 +1,89 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ +package org.hornetq.javaee.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageConsumer; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +/** + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + */ +public class MDBMessageSendTxClientExample +{ + public static void main(String[] args) throws Exception + { + Connection connection = null; + InitialContext initialContext = null; + try + { + //Step 1. Create an initial context to perform the JNDI lookup. + initialContext = new InitialContext(); + + //Step 2. Perfom a lookup on the queue + Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); + + //Step 3. Perform a lookup on the Connection Factory + ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); + + //Step 4.Create a JMS Connection + connection = cf.createConnection(); + + //Step 5. Create a JMS Session + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + + //Step 6. Create a JMS Message Producer + MessageProducer producer = session.createProducer(queue); + + //Step 7. Create a Text Message + TextMessage message = session.createTextMessage("This is a text message"); + + System.out.println("Sent message: " + message.getText()); + + //Step 8. Send the Message + producer.send(message); + + //Step 15. We lookup the reply queue + queue = (Queue) initialContext.lookup("/queue/replyQueue"); + + //Step 16. We create a JMS message consumer + MessageConsumer messageConsumer = session.createConsumer(queue); + + //Step 17. We start the connedction so we can receive messages + connection.start(); + + //Step 18. We receive the message and print it out + message = (TextMessage) messageConsumer.receive(5000); + + System.out.println("message.getText() = " + message.getText()); + + } + finally + { + //Step 19. Be sure to close our JMS resources! + if (initialContext != null) + { + initialContext.close(); + } + if(connection != null) + { + connection.close(); + } + } + } +} \ No newline at end of file Added: trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/server/MDBMessageSendTxExample.java =================================================================== --- trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/server/MDBMessageSendTxExample.java (rev 0) +++ trunk/examples/javaee/mdb-tx-send/src/org/hornetq/javaee/example/server/MDBMessageSendTxExample.java 2009-08-21 13:25:26 UTC (rev 7866) @@ -0,0 +1,95 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ +package org.hornetq.javaee.example.server; + +import javax.annotation.Resource; +import javax.ejb.ActivationConfigProperty; +import javax.ejb.MessageDriven; +import javax.ejb.TransactionAttribute; +import javax.ejb.TransactionAttributeType; +import javax.ejb.TransactionManagement; +import javax.ejb.TransactionManagementType; +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.JMSException; +import javax.jms.Message; +import javax.jms.MessageListener; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; + +/** + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + */ +@MessageDriven(name = "MDBMessageSendTxExample", + activationConfig = + { + @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"), + @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue") + }) +@TransactionManagement(value= TransactionManagementType.CONTAINER) +@TransactionAttribute(value= TransactionAttributeType.REQUIRED) +public class MDBMessageSendTxExample implements MessageListener +{ + @Resource(mappedName = "java:JmsXA") + ConnectionFactory connectionFactory; + + @Resource(mappedName = "queue/replyQueue") + Queue replyQueue; + + public void onMessage(Message message) + { + Connection conn = null; + try + { + //Step 9. We know the client is sending a text message so we cast + TextMessage textMessage = (TextMessage)message; + + //Step 10. get the text from the message. + String text = textMessage.getText(); + + System.out.println("message " + text); + + //Step 11. we create a JMS connection + conn = connectionFactory.createConnection(); + + //Step 12. We create a JMS session + Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + //Step 13. we create a producer for the reply queue + MessageProducer producer = sess.createProducer(replyQueue); + + //Step 14. we create a message and send it + producer.send(sess.createTextMessage("this is a reply")); + + } + catch (Exception e) + { + e.printStackTrace(); + } + finally + { + if(conn != null) + { + try + { + conn.close(); + } + catch (JMSException e) + { + } + } + } + } +} \ No newline at end of file