[hornetq-commits] JBoss hornetq SVN: r7864 - in trunk/examples/javaee: jca-config and 8 other directories.

Author: ataylor Date: 2009-08-21 08:52:42 -0400 (Fri, 21 Aug 2009) New Revision: 7864 Added: trunk/examples/javaee/jca-config/server2/hornetq-configuration.xml trunk/examples/javaee/jca-config/src/org/hornetq/ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/MDBRemoteClientExample.java trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server/ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server/MDBQueueA.java trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/MDBQueueB.java trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/StatelessSender.java trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/StatelessSenderService.java Modified: trunk/examples/javaee/common/build.xml trunk/examples/javaee/jca-config/build.xml trunk/examples/javaee/jca-config/server/hornetq-configuration.xml Log: readded jca-config example and build fix Modified: trunk/examples/javaee/common/build.xml =================================================================== --- trunk/examples/javaee/common/build.xml 2009-08-21 11:51:41 UTC (rev 7863) +++ trunk/examples/javaee/common/build.xml 2009-08-21 12:52:42 UTC (rev 7864) @@ -91,7 +91,7 @@ <target name="jar" depends="compile"> <jar destfile="${build.dir}/${example.name}-example.jar" basedir="${classes.dir}" - includes="org/jboss/javaee/example/server/**/*"> + includes="org/hornetq/javaee/example/server/**/*"> </jar> </target> Modified: trunk/examples/javaee/jca-config/build.xml =================================================================== --- trunk/examples/javaee/jca-config/build.xml 2009-08-21 11:51:41 UTC (rev 7863) +++ trunk/examples/javaee/jca-config/build.xml 2009-08-21 12:52:42 UTC (rev 7864) @@ -19,7 +19,7 @@ <target name="jar2" depends="compile"> <jar destfile="${build.dir}/jca-config-example2.jar" basedir="${classes.dir}" - includes="org/jboss/javaee/example/server2/**/*"> + includes="org/hornetq/javaee/example/server2/**/*"> </jar> </target> <target name="ear2" depends="jar2"> @@ -42,9 +42,10 @@ <exclude name="**/tmp/**"/> </fileset> </copy> - <copy todir="${deploy.dir2}/deploy/hornetq.sar"> + <copy todir="${deploy.dir2}/deploy/hornetq.sar" overwrite="true"> <fileset dir="server2"> <include name="jms-remote-ds.xml"/> + <include name="hornetq-configuration.xml"/> </fileset> </copy> <copy todir="${deploy.dir2}/deploy/jms-ra.rar/META-INF"> Modified: trunk/examples/javaee/jca-config/server/hornetq-configuration.xml =================================================================== --- trunk/examples/javaee/jca-config/server/hornetq-configuration.xml 2009-08-21 11:51:41 UTC (rev 7863) +++ trunk/examples/javaee/jca-config/server/hornetq-configuration.xml 2009-08-21 12:52:42 UTC (rev 7864) @@ -33,7 +33,7 @@ <!-- Netty TCP Acceptor --> <acceptor name="netty"> <factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory</factory-class> - <param key="hornetq.remoting.netty.port" value="${hornetq.remoting.netty.port}" type="Integer"/> + <param key="hornetq.remoting.netty.port" value="${hornetq.remoting.netty.port:5445}" type="Integer"/> </acceptor> </acceptors> Copied: trunk/examples/javaee/jca-config/server2/hornetq-configuration.xml (from rev 7854, trunk/examples/javaee/jca-config/server/hornetq-configuration.xml) =================================================================== --- trunk/examples/javaee/jca-config/server2/hornetq-configuration.xml (rev 0) +++ trunk/examples/javaee/jca-config/server2/hornetq-configuration.xml 2009-08-21 12:52:42 UTC (rev 7864) @@ -0,0 +1,56 @@ +<!-- + ~ Copyright (c) 2009. Lorem ipsum dolor sit amet, consectetur adipiscing elit. + ~ Morbi non lorem porttitor neque feugiat blandit. Ut vitae ipsum eget quam lacinia accumsan. + ~ Etiam sed turpis ac ipsum condimentum fringilla. Maecenas magna. + ~ Proin dapibus sapien vel ante. Aliquam erat volutpat. Pellentesque sagittis ligula eget metus. + ~ Vestibulum commodo. Ut rhoncus gravida arcu. + --> + +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd"> + + <bindings-directory>${jboss.server.data.dir}/messaging/bindings</bindings-directory> + + <journal-directory>${jboss.server.data.dir}/messaging/journal</journal-directory> + + <large-messages-directory>${jboss.server.data.dir}/messaging/largemessages</large-messages-directory> + + <paging-directory>${jboss.server.data.dir}/messaging/paging</paging-directory> + + <!-- Connectors --> + <connectors> + <connector name="netty"> + <factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory</factory-class> + </connector> + + <connector name="in-vm"> + <factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class> + </connector> + + </connectors> + + <!-- Acceptors --> + <acceptors> + <!-- In VM acceptor --> + <acceptor name="in-vm"> + <factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class> + <param key="hornetq.remoting.invm.serverid" value="0" type="Integer"/> + </acceptor> + + <!-- Netty TCP Acceptor --> + <acceptor name="netty"> + <factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory</factory-class> + <param key="hornetq.remoting.netty.port" value="${hornetq.remoting.netty.port:5446}" type="Integer"/> + </acceptor> + </acceptors> + + <security-settings> + <security-setting match="jms.queue.#"> + <permission type="consume" roles="guest,publisher"/> + <permission type="send" roles="guest,publisher"/> + </security-setting> + </security-settings> + + +</configuration> Added: trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/MDBRemoteClientExample.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/MDBRemoteClientExample.java (rev 0) +++ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/MDBRemoteClientExample.java 2009-08-21 12:52:42 UTC (rev 7864) @@ -0,0 +1,60 @@ +/* + * 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 org.hornetq.javaee.example.server2.StatelessSenderService; + +import javax.jms.Connection; +import javax.naming.InitialContext; + +/** + * + * MDB Remote & JCA Configuration Example. + * + * @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a> + */ +public class MDBRemoteClientExample +{ + 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. Getting a reference to the Stateless Bean + StatelessSenderService sender = (StatelessSenderService)initialContext.lookup("jca-config-example2/StatelessSender/remote"); + + //Step 3. Calling a Stateless Session Bean. You will have more steps on the SessionBean + sender.sendHello("Hello there MDB!"); + + System.out.println("Step 3: Invoking the Stateless Bean"); + + initialContext.close(); + } + finally + { + //Step 11. Be sure to close our JMS resources! + if (initialContext != null) + { + initialContext.close(); + } + if(connection != null) + { + connection.close(); + } + } + } +} Added: trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server/MDBQueueA.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server/MDBQueueA.java (rev 0) +++ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server/MDBQueueA.java 2009-08-21 12:52:42 UTC (rev 7864) @@ -0,0 +1,52 @@ +/* + * 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.ejb.ActivationConfigProperty; +import javax.ejb.MessageDriven; +import javax.jms.Message; +import javax.jms.MessageListener; +import javax.jms.TextMessage; + +/** + * MDB that is connected to the remote queue. + * @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a> + */ + +//Step 9. The message is received on the MDB, using a local queue. +@MessageDriven(name = "MDB_QueueA", + activationConfig = + { + @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"), + @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/A"), + @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") + }) +public class MDBQueueA implements MessageListener +{ + public void onMessage(Message message) + { + try + { + TextMessage tm = (TextMessage)message; + + String text = tm.getText(); + + System.out.println("Step 10: (MDBQueueA.java) Message received using the default adapter. Message = \"" + text + "\"" ); + + } + catch (Exception e) + { + e.printStackTrace(); + } + } +} Added: trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/MDBQueueB.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/MDBQueueB.java (rev 0) +++ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/MDBQueueB.java 2009-08-21 12:52:42 UTC (rev 7864) @@ -0,0 +1,52 @@ +/* + * 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.server2; + +import javax.ejb.ActivationConfigProperty; +import javax.ejb.MessageDriven; +import javax.jms.Message; +import javax.jms.MessageListener; +import javax.jms.TextMessage; + +/** + * MDB that is connected to the remote queue. + * @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a> + */ + +//Step 10. The message is received on the MDB, using a remote queue. +@MessageDriven(name = "MDB_QueueB", + activationConfig = + { + @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"), + @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/B"), + @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") + }) +public class MDBQueueB implements MessageListener +{ + public void onMessage(Message message) + { + try + { + TextMessage tm = (TextMessage)message; + + String text = tm.getText(); + + System.out.println("Step 11: (MDBQueueB.java) Message received using the remote adapter. Message = \"" + text + "\"" ); + + } + catch (Exception e) + { + e.printStackTrace(); + } + } +} Added: trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/StatelessSender.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/StatelessSender.java (rev 0) +++ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/StatelessSender.java 2009-08-21 12:52:42 UTC (rev 7864) @@ -0,0 +1,97 @@ +/* + * 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.server2; + + + +import org.hornetq.jms.HornetQQueue; + +import javax.annotation.Resource; +import javax.ejb.Remote; +import javax.ejb.Stateless; +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageProducer; +import javax.jms.Session; + +/** + * A Stateless Bean that will connect to a remote JBM. + * + * @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a> + * + * + */ +(a)Remote(StatelessSenderService.class) +@Stateless +public class StatelessSender implements StatelessSenderService +{ + + /** + * Resource to be deployed by jms-remote-ds.xml + * */ + @Resource(mappedName="java:RemoteJmsXA") + private ConnectionFactory connectionFactory; + + + /* (non-Javadoc) + * @see org.jboss.javaee.example.server.StatelessSenderService#sendHello(java.lang.String) + */ + public void sendHello(String message) throws Exception + { + // Step 4. Define the destinations that will receive the message (instead of using JNDI to the remote server) + HornetQQueue destQueueA = new HornetQQueue("A"); + HornetQQueue destQueueB = new HornetQQueue("B"); + + // Step 5. Create a connection to a remote server using a connection-factory (look at the deployed file jms-remote-ds.xml) + Connection conn = connectionFactory.createConnection("guest", "guest"); + + // Step 6. Send a message to a QueueA on the remote server, which will be received by MDBQueueA + Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + MessageProducer prodA = sess.createProducer(destQueueA); + prodA.send(sess.createTextMessage(message)); + + System.out.println("Step 7 (StatelessSender.java): Sent message \"" + message + "\" to QueueA"); + + // Step 6. Send a message to a QueueB on the remote server, which will be received by MDBQueueA + MessageProducer prodB = sess.createProducer(destQueueB); + prodB.send(sess.createTextMessage(message)); + + System.out.println("Step 8 (StatelessSender.java): Sent message \"" + message + "\" to QueueB"); + + // Step 7. Close the connection. (Since this is a JCA connection, this will just place the connection back to a connection pool) + conn.close(); + System.out.println("Step 9 (StatelessSender.java): Closed Connection (sending it back to pool)"); + + } + + // Constants ----------------------------------------------------- + + // Attributes ---------------------------------------------------- + + // Static -------------------------------------------------------- + + // Constructors -------------------------------------------------- + + // Public -------------------------------------------------------- + + // Package protected --------------------------------------------- + + // Protected ----------------------------------------------------- + + // Private ------------------------------------------------------- + + // Inner classes ------------------------------------------------- + +} Added: trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/StatelessSenderService.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/StatelessSenderService.java (rev 0) +++ trunk/examples/javaee/jca-config/src/org/hornetq/javaee/example/server2/StatelessSenderService.java 2009-08-21 12:52:42 UTC (rev 7864) @@ -0,0 +1,29 @@ +/* + * 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.server2; + +/** + * A StatelessSenderService + * + * @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a> + * + * + */ +public interface StatelessSenderService +{ + + public void sendHello(String message) throws Exception; + +}