Author: bill.burke(a)jboss.com Date: 2010-09-02 19:21:38 -0400 (Thu, 02 Sep 2010) New Revision: 9631 Added: trunk/examples/jms/embedded-simple/ trunk/examples/jms/embedded-simple/build.bat trunk/examples/jms/embedded-simple/build.sh trunk/examples/jms/embedded-simple/build.xml trunk/examples/jms/embedded-simple/readme.html trunk/examples/jms/embedded-simple/server0/ trunk/examples/jms/embedded-simple/server0/hornetq-configuration.xml trunk/examples/jms/embedded-simple/server0/hornetq-jms.xml trunk/examples/jms/embedded-simple/server0/hornetq-users.xml trunk/examples/jms/embedded-simple/src/ trunk/examples/jms/embedded-simple/src/org/ trunk/examples/jms/embedded-simple/src/org/hornetq/ trunk/examples/jms/embedded-simple/src/org/hornetq/jms/ trunk/examples/jms/embedded-simple/src/org/hornetq/jms/example/ trunk/examples/jms/embedded-simple/src/org/hornetq/jms/example/EmbeddedExample.java trunk/examples/jms/spring-integration/ trunk/examples/jms/spring-integration/build.bat trunk/examples/jms/spring-integration/build.sh trunk/examples/jms/spring-integration/build.xml trunk/examples/jms/spring-integration/readme.html trunk/examples/jms/spring-integration/server0/ trunk/examples/jms/spring-integration/server0/hornetq-configuration.xml trunk/examples/jms/spring-integration/server0/hornetq-jms.xml trunk/examples/jms/spring-integration/server0/hornetq-users.xml trunk/examples/jms/spring-integration/server0/spring-jms-beans.xml trunk/examples/jms/spring-integration/src/ trunk/examples/jms/spring-integration/src/org/ trunk/examples/jms/spring-integration/src/org/hornetq/ trunk/examples/jms/spring-integration/src/org/hornetq/jms/ trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/ trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/ExampleListener.java trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/MessageSender.java trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/SpringExample.java Modified: trunk/examples/jms/embedded/src/org/hornetq/jms/example/EmbeddedExample.java trunk/src/main/org/hornetq/core/registry/MapBindingRegistry.java trunk/src/main/org/hornetq/core/server/embedded/EmbeddedHornetQ.java trunk/src/main/org/hornetq/jms/server/embedded/EmbeddedJMS.java Log: added new examples for spring and embedded, reworked embedded example Modified: trunk/examples/jms/embedded/src/org/hornetq/jms/example/EmbeddedExample.java =================================================================== --- trunk/examples/jms/embedded/src/org/hornetq/jms/example/EmbeddedExample.java 2010-09-02 23:20:36 UTC (rev 9630) +++ trunk/examples/jms/embedded/src/org/hornetq/jms/example/EmbeddedExample.java 2010-09-02 23:21:38 UTC (rev 9631) @@ -12,42 +12,34 @@ */ package org.hornetq.jms.example; -import java.util.Date; -import java.util.Hashtable; - -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.Context; -import javax.naming.InitialContext; - import org.hornetq.api.core.TransportConfiguration; import org.hornetq.core.config.Configuration; import org.hornetq.core.config.impl.ConfigurationImpl; import org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory; import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; -import org.hornetq.core.server.HornetQServer; -import org.hornetq.core.server.HornetQServers; -import org.hornetq.jms.server.JMSServerManager; import org.hornetq.jms.server.config.ConnectionFactoryConfiguration; import org.hornetq.jms.server.config.JMSConfiguration; import org.hornetq.jms.server.config.JMSQueueConfiguration; import org.hornetq.jms.server.config.impl.ConnectionFactoryConfigurationImpl; import org.hornetq.jms.server.config.impl.JMSConfigurationImpl; import org.hornetq.jms.server.config.impl.JMSQueueConfigurationImpl; -import org.hornetq.jms.server.impl.JMSServerManagerImpl; -import org.jnp.server.Main; -import org.jnp.server.NamingBeanImpl; +import org.hornetq.jms.server.embedded.EmbeddedJMS; +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 java.util.Date; + /** * This example demonstrates how to run a HornetQ embedded with JMS * * @author <a href=&quot;clebert.suconic(a)jboss.com&quot;&gt;Clebert Suconic</a> * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> + * @author <a href="mailto:bburke@redhat.com">Bill Burke</a> */ public class EmbeddedExample { @@ -64,51 +56,30 @@ configuration.getAcceptorConfigurations() .add(new TransportConfiguration(NettyAcceptorFactory.class.getName())); - // Step 2. Create HornetQ core server - HornetQServer hornetqServer = HornetQServers.newHornetQServer(configuration); - - // Step 3. Create and start the JNDI server - System.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory"); - NamingBeanImpl naming = new NamingBeanImpl(); - naming.start(); - Main jndiServer = new Main(); - jndiServer.setNamingInfo(naming); - jndiServer.setPort(1099); - jndiServer.setBindAddress("localhost"); - jndiServer.setRmiPort(1098); - jndiServer.setRmiBindAddress("localhost"); - jndiServer.start(); - - // Step 4. Create the JMS configuration + // Step 2. Create the JMS configuration JMSConfiguration jmsConfig = new JMSConfigurationImpl(); - // Step 5. Configure context used to bind the JMS resources to JNDI - Hashtable<String, String> env = new Hashtable<String, String>(); - env.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory"); - env.put("java.naming.provider.url", "jnp://localhost:1099"); - env.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces"); - Context context = new InitialContext(env); - jmsConfig.setContext(context); - - // Step 6. Configure the JMS ConnectionFactory + // Step 3. Configure the JMS ConnectionFactory TransportConfiguration connectorConfig = new TransportConfiguration(NettyConnectorFactory.class.getName()); ConnectionFactoryConfiguration cfConfig = new ConnectionFactoryConfigurationImpl("cf", connectorConfig, "/cf"); jmsConfig.getConnectionFactoryConfigurations().add(cfConfig); - // Step 7. Configure the JMS Queue + // Step 4. Configure the JMS Queue JMSQueueConfiguration queueConfig = new JMSQueueConfigurationImpl("queue1", null, false, "/queue/queue1"); jmsConfig.getQueueConfigurations().add(queueConfig); - // Step 8. Start the JMS Server using the HornetQ core server and the JMS configuration - JMSServerManager jmsServer = new JMSServerManagerImpl(hornetqServer, jmsConfig); + // Step 5. Start the JMS Server using the HornetQ core server and the JMS configuration + EmbeddedJMS jmsServer = new EmbeddedJMS(); + jmsServer.setConfiguration(configuration); + jmsServer.setJmsConfiguration(jmsConfig); jmsServer.start(); System.out.println("Started Embedded JMS Server"); - // Step 9. Lookup JMS resources defined in the configuration - ConnectionFactory cf = (ConnectionFactory)context.lookup("/cf"); - Queue queue = (Queue)context.lookup("/queue/queue1"); + // Step 6. Lookup JMS resources defined in the configuration + ConnectionFactory cf = (ConnectionFactory)jmsServer.lookup("/cf"); + Queue queue = (Queue)jmsServer.lookup("/queue/queue1"); - // Step 10. Send and receive a message using JMS API + // Step 7. Send and receive a message using JMS API Connection connection = null; try { @@ -134,9 +105,6 @@ jmsServer.stop(); System.out.println("Stopped the JMS Server"); - // Step 12. Stop the JNDI server - naming.stop(); - jndiServer.stop(); System.exit(0); } } Added: trunk/examples/jms/embedded-simple/build.bat =================================================================== --- trunk/examples/jms/embedded-simple/build.bat (rev 0) +++ trunk/examples/jms/embedded-simple/build.bat 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,13 @@ +@echo off + +set "OVERRIDE_ANT_HOME=..\..\..\tools\ant" + +if exist "..\..\..\src\bin\build.bat" ( + rem running from TRUNK + call ..\..\..\src\bin\build.bat %* +) else ( + rem running from the distro + call ..\..\..\bin\build.bat %* +) + +set "OVERRIDE_ANT_HOME=" Added: trunk/examples/jms/embedded-simple/build.sh =================================================================== --- trunk/examples/jms/embedded-simple/build.sh (rev 0) +++ trunk/examples/jms/embedded-simple/build.sh 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,15 @@ +#!/bin/sh + +OVERRIDE_ANT_HOME=../../../tools/ant +export OVERRIDE_ANT_HOME + +if [ -f "../../../src/bin/build.sh" ]; then + # running from TRUNK + ../../../src/bin/build.sh "$@" +else + # running from the distro + ../../../bin/build.sh "$@" +fi + + + Property changes on: trunk/examples/jms/embedded-simple/build.sh ___________________________________________________________________ Name: svn:executable + * Added: trunk/examples/jms/embedded-simple/build.xml =================================================================== --- trunk/examples/jms/embedded-simple/build.xml (rev 0) +++ trunk/examples/jms/embedded-simple/build.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,54 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE project [ + <!ENTITY libraries SYSTEM "../../../thirdparty/libraries.ent"> + ]> +<!-- + ~ 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. + --> + +<project default="run" name="HornetQ Embedded Example"> + + <import file="../../common/build.xml"/> + + <path id="local.classpath"> + <fileset dir="${hornetq.jars.dir}"> + <include name="hornetq-core.jar"/> + <include name="hornetq-jms.jar"/> + </fileset> + + <fileset dir="${jars.dir}"> + <include name="**/jboss-jms-api.jar"/> + <include name="**/netty.jar"/> + </fileset> + + <pathelement location="${classes.dir}"/> + <pathelement location="server0"/> + </path> + + <target name="run" depends="compile"> + <java classname="org.hornetq.jms.example.EmbeddedExample" fork="true" resultproperty="example-result"> + <jvmarg value="-Xms50M"/> + <jvmarg value="-Xmx50M"/> + <classpath refid="local.classpath"/> + </java> + + <!-- if the example exited with a result value != 0, we fail the build --> + <fail message="Example EmbeddedExample failed"> + <condition> + <not> + <equals arg1="${example-result}" arg2="0"/> + </not> + </condition> + </fail> + + </target> +</project> Added: trunk/examples/jms/embedded-simple/readme.html =================================================================== --- trunk/examples/jms/embedded-simple/readme.html (rev 0) +++ trunk/examples/jms/embedded-simple/readme.html 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,52 @@ +<html> + <head> + <title>HornetQ Embedded JMS Server Example</title> + <link rel="stylesheet" type="text/css" href="../../common/common.css" /> + <link rel="stylesheet" type="text/css" href="../../common/prettify.css" /> + <script type="text/javascript" src="../../common/prettify.js"></script> + </head> + <body onload="prettyPrint()"> + <h1>Embedded JMS Server Example</h1> + + <p>This examples shows how to setup and run an embedded JMS server using HornetQ along with HornetQ configuration files.</p> + + <h2>Example step-by-step</h2> + <p><i>To run the example, simply type <code>./build.sh</code> (or <code>build.bat</code> on windows) from this directory</i></p> + + <ol> + <li>Create HornetQ core configuration files and make sure they are within your classpath. By default, HornetQ + expects the classnames to be "hornetq-configuration.xml", "hornetq-jms.xml", and "hornetq-users.xml".</li> + <li>Create and start HornetQ JMS server</li> + <pre class="prettyprint"> + <code>EmbeddedJMS jmsServer = new EmbeddedJMS(); + jmsServer.start();</code> + </pre> + + <p>At this point the JMS server is started and any JMS clients can look up JMS resources from the JNDI to send/receive + messages from the server. To keep the example simple, we will send and receive a JMS message from the same JVM + used to run the JMS server.</p> + + <li>Lookup JMS resources defined in the configuration </li> + <pre class="prettyprint"> + <code>ConnectionFactory cf = (ConnectionFactory)context.lookup("/cf"); + Queue queue = (Queue)context.lookup("/queue/queue1");</code> + </pre> + + <li>Send and receive a message using JMS API</li> + <p>See the <a href="../queue/readme.html">Queue Example</a> for detailed steps to send and receive a JMS message</p> + + <p>Finally, we stop the JMS server and its associated resources.</p> + + <li>Stop the JMS server</li> + <pre class="prettyprint"> + <code>jmsServer.stop();</code> + </pre> + + <li>Stop the JNDI server</li> + <pre class="prettyprint"> + <code>naming.stop(); + jndiServer.stop();</code> + </pre> + </ol> + </body> +</html> \ No newline at end of file Added: trunk/examples/jms/embedded-simple/server0/hornetq-configuration.xml =================================================================== --- trunk/examples/jms/embedded-simple/server0/hornetq-configuration.xml (rev 0) +++ trunk/examples/jms/embedded-simple/server0/hornetq-configuration.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,34 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd"> + + <persistence-enabled>false</persistence-enabled> + <!-- Connectors --> + + <connectors> + <connector name="in-vm"> + <factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class> + </connector> + </connectors> + + <acceptors> + <acceptor name="in-vm"> + <factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class> + </acceptor> + </acceptors> + + <!-- Other config --> + + <security-settings> + <!--security for example queue--> + <security-setting match="#"> + <permission type="createDurableQueue" roles="guest"/> + <permission type="deleteDurableQueue" roles="guest"/> + <permission type="createNonDurableQueue" roles="guest"/> + <permission type="deleteNonDurableQueue" roles="guest"/> + <permission type="consume" roles="guest"/> + <permission type="send" roles="guest"/> + </security-setting> + </security-settings> + +</configuration> Added: trunk/examples/jms/embedded-simple/server0/hornetq-jms.xml =================================================================== --- trunk/examples/jms/embedded-simple/server0/hornetq-jms.xml (rev 0) +++ trunk/examples/jms/embedded-simple/server0/hornetq-jms.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,19 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"> + <!--the connection factory used by the example--> + <connection-factory name="ConnectionFactory"> + <connectors> + <connector-ref connector-name="in-vm"/> + </connectors> + <entries> + <entry name="ConnectionFactory"/> + </entries> + </connection-factory> + + <!--the queue used by the example--> + <queue name="exampleQueue"> + <entry name="/queue/exampleQueue"/> + </queue> + +</configuration> Added: trunk/examples/jms/embedded-simple/server0/hornetq-users.xml =================================================================== --- trunk/examples/jms/embedded-simple/server0/hornetq-users.xml (rev 0) +++ trunk/examples/jms/embedded-simple/server0/hornetq-users.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,7 @@ +<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd"> + <!-- the default user. this is used where username is null--> + <defaultuser name="guest" password="guest"> + <role name="guest"/> + </defaultuser> +</configuration> \ No newline at end of file Added: trunk/examples/jms/embedded-simple/src/org/hornetq/jms/example/EmbeddedExample.java =================================================================== --- trunk/examples/jms/embedded-simple/src/org/hornetq/jms/example/EmbeddedExample.java (rev 0) +++ trunk/examples/jms/embedded-simple/src/org/hornetq/jms/example/EmbeddedExample.java 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,83 @@ +/* + * 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.jms.example; + +import java.util.Date; +import java.util.Hashtable; + +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 org.hornetq.jms.server.embedded.EmbeddedJMS; + +/** + * This example demonstrates how to run a HornetQ embedded with JMS + * + * @author <a href=&quot;clebert.suconic(a)jboss.com&quot;&gt;Clebert Suconic</a> + * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> + */ +public class EmbeddedExample +{ + + public static void main(final String[] args) + { + try + { + EmbeddedJMS jmsServer = new EmbeddedJMS(); + jmsServer.start(); + System.out.println("Started Embedded JMS Server"); + + ConnectionFactory cf = (ConnectionFactory)jmsServer.lookup("/cf"); + Queue queue = (Queue)jmsServer.lookup("/queue/exampleQueue"); + + // Step 10. Send and receive a message using JMS API + Connection connection = null; + try + { + connection = cf.createConnection(); + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + MessageProducer producer = session.createProducer(queue); + TextMessage message = session.createTextMessage("Hello sent at " + new Date()); + System.out.println("Sending message: " + message.getText()); + producer.send(message); + MessageConsumer messageConsumer = session.createConsumer(queue); + connection.start(); + TextMessage messageReceived = (TextMessage)messageConsumer.receive(1000); + System.out.println("Received message:" + messageReceived.getText()); + } + finally + { + if (connection != null) + { + connection.close(); + } + + // Step 11. Stop the JMS server + jmsServer.stop(); + System.out.println("Stopped the JMS Server"); + System.exit(0); + } + } + catch (Exception e) + { + e.printStackTrace(); + System.exit(-1); + } + } + +} Added: trunk/examples/jms/spring-integration/build.bat =================================================================== --- trunk/examples/jms/spring-integration/build.bat (rev 0) +++ trunk/examples/jms/spring-integration/build.bat 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,13 @@ +@echo off + +set "OVERRIDE_ANT_HOME=..\..\..\tools\ant" + +if exist "..\..\..\src\bin\build.bat" ( + rem running from TRUNK + call ..\..\..\src\bin\build.bat %* +) else ( + rem running from the distro + call ..\..\..\bin\build.bat %* +) + +set "OVERRIDE_ANT_HOME=" Added: trunk/examples/jms/spring-integration/build.sh =================================================================== --- trunk/examples/jms/spring-integration/build.sh (rev 0) +++ trunk/examples/jms/spring-integration/build.sh 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,15 @@ +#!/bin/sh + +OVERRIDE_ANT_HOME=../../../tools/ant +export OVERRIDE_ANT_HOME + +if [ -f "../../../src/bin/build.sh" ]; then + # running from TRUNK + ../../../src/bin/build.sh "$@" +else + # running from the distro + ../../../bin/build.sh "$@" +fi + + + Property changes on: trunk/examples/jms/spring-integration/build.sh ___________________________________________________________________ Name: svn:executable + * Added: trunk/examples/jms/spring-integration/build.xml =================================================================== --- trunk/examples/jms/spring-integration/build.xml (rev 0) +++ trunk/examples/jms/spring-integration/build.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,64 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE project [ + <!ENTITY libraries SYSTEM "../../../thirdparty/libraries.ent"> + ]> +<!-- + ~ 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. + --> + +<project default="run" name="HornetQ Embedded Example"> + + <import file="../../common/build.xml"/> + <echo message = "Do not forget to add the Spring jars to your classpath!!!!!!!"/> + <path id="extra.classpath"> + <fileset dir="${jars.dir}"> + <include name="**/spring*.jar"/> + <include name="**/commons-logging.jar"/> + </fileset> + </path> + + <path id="local.classpath"> + <fileset dir="${hornetq.jars.dir}"> + <include name="hornetq-core.jar"/> + <include name="hornetq-jms.jar"/> + <include name="hornetq-spring-integration.jar"/> + </fileset> + + <fileset dir="${jars.dir}"> + <include name="**/jboss-jms-api.jar"/> + <include name="**/netty.jar"/> + <include name="**/spring*.jar"/> + <include name="**/commons-logging.jar"/> + </fileset> + + <pathelement location="${classes.dir}"/> + <pathelement location="server0"/> + </path> + + <target name="run" depends="compile"> + <java classname="org.hornetq.jms.example.SpringExample" fork="true" resultproperty="example-result"> + <jvmarg value="-Xms50M"/> + <jvmarg value="-Xmx50M"/> + <classpath refid="local.classpath"/> + </java> + + <!-- if the example exited with a result value != 0, we fail the build --> + <fail message="Example SpringExample failed"> + <condition> + <not> + <equals arg1="${example-result}" arg2="0"/> + </not> + </condition> + </fail> + + </target> +</project> Added: trunk/examples/jms/spring-integration/readme.html =================================================================== --- trunk/examples/jms/spring-integration/readme.html (rev 0) +++ trunk/examples/jms/spring-integration/readme.html 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,17 @@ +<html> + <head> + <title>HornetQ Spring Example</title> + <link rel="stylesheet" type="text/css" href="../../common/common.css" /> + <link rel="stylesheet" type="text/css" href="../../common/prettify.css" /> + <script type="text/javascript" src="../../common/prettify.js"></script> + </head> + <body onload="prettyPrint()"> + <h1>HornetQ Spring Example</h1> + + <p>This examples shows how to setup and run an embedded JMS server within a Spring ApplicationContext using HornetQ along with HornetQ configuration files.</p> + + <h2>Example step-by-step</h2> + <p><i><b>YOU MUST DOWNLOAD THE SPRING LIBRARIES TO RUN THIS EXAMPLE!!!</b> You must also modify the build.xml file to include the spring jars. You'll see the placeholder that is already there.</i></p> + <p><i>To run the example, simply type <code>./build.sh</code> (or <code>build.bat</code> on windows) from this directory</i></p> + </body> +</html> Added: trunk/examples/jms/spring-integration/server0/hornetq-configuration.xml =================================================================== --- trunk/examples/jms/spring-integration/server0/hornetq-configuration.xml (rev 0) +++ trunk/examples/jms/spring-integration/server0/hornetq-configuration.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,34 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd"> + + <persistence-enabled>false</persistence-enabled> + <!-- Connectors --> + + <connectors> + <connector name="in-vm"> + <factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class> + </connector> + </connectors> + + <acceptors> + <acceptor name="in-vm"> + <factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class> + </acceptor> + </acceptors> + + <!-- Other config --> + + <security-settings> + <!--security for example queue--> + <security-setting match="#"> + <permission type="createDurableQueue" roles="guest"/> + <permission type="deleteDurableQueue" roles="guest"/> + <permission type="createNonDurableQueue" roles="guest"/> + <permission type="deleteNonDurableQueue" roles="guest"/> + <permission type="consume" roles="guest"/> + <permission type="send" roles="guest"/> + </security-setting> + </security-settings> + +</configuration> Added: trunk/examples/jms/spring-integration/server0/hornetq-jms.xml =================================================================== --- trunk/examples/jms/spring-integration/server0/hornetq-jms.xml (rev 0) +++ trunk/examples/jms/spring-integration/server0/hornetq-jms.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,19 @@ +<configuration xmlns="urn:hornetq" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"> + <!--the connection factory used by the example--> + <connection-factory name="ConnectionFactory"> + <connectors> + <connector-ref connector-name="in-vm"/> + </connectors> + <entries> + <entry name="ConnectionFactory"/> + </entries> + </connection-factory> + + <!--the queue used by the example--> + <queue name="exampleQueue"> + <entry name="/queue/exampleQueue"/> + </queue> + +</configuration> Added: trunk/examples/jms/spring-integration/server0/hornetq-users.xml =================================================================== --- trunk/examples/jms/spring-integration/server0/hornetq-users.xml (rev 0) +++ trunk/examples/jms/spring-integration/server0/hornetq-users.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,7 @@ +<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd"> + <!-- the default user. this is used where username is null--> + <defaultuser name="guest" password="guest"> + <role name="guest"/> + </defaultuser> +</configuration> \ No newline at end of file Added: trunk/examples/jms/spring-integration/server0/spring-jms-beans.xml =================================================================== --- trunk/examples/jms/spring-integration/server0/spring-jms-beans.xml (rev 0) +++ trunk/examples/jms/spring-integration/server0/spring-jms-beans.xml 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,24 @@ +<?xml version="1.0" encoding="UTF-8"?> +<beans xmlns="http://www.springframework.org/schema/beans" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://www.springframework.org/schema/beans + http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> + + <bean id="EmbeddedJms" class="org.hornetq.integration.spring.SpringJmsBootstrap" init-method="start" destroy-method="stop"/> + + <bean id="listener" class="org.hornetq.jms.example.ExampleListener"/> + + <bean id="MessageSender" class="org.hornetq.jms.example.MessageSender"> + <property name="connectionFactory" ref="ConnectionFactory"/> + <property name="destination" ref="/queue/exampleQueue"/> + </bean> + + <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> + <property name="connectionFactory" ref="ConnectionFactory"/> + <property name="destination" ref="/queue/exampleQueue"/> + <property name="messageListener" ref="listener"/> + </bean> + + +</beans> + \ No newline at end of file Added: trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/ExampleListener.java =================================================================== --- trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/ExampleListener.java (rev 0) +++ trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/ExampleListener.java 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,28 @@ +package org.hornetq.jms.example; + +import javax.jms.JMSException; +import javax.jms.Message; +import javax.jms.MessageListener; +import javax.jms.TextMessage; + +/** + * @author <a href="mailto:bill@burkecentral.com">Bill Burke</a> + * @version $Revision: 1 $ + */ +public class ExampleListener implements MessageListener +{ + public static String lastMessage = null; + + public void onMessage(Message message) + { + try + { + lastMessage = ((TextMessage)message).getText(); + } + catch (JMSException e) + { + throw new RuntimeException(e); + } + System.out.println("MESSAGE RECEIVED: " + lastMessage); + } +} Added: trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/MessageSender.java =================================================================== --- trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/MessageSender.java (rev 0) +++ trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/MessageSender.java 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,54 @@ +package org.hornetq.jms.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.Destination; +import javax.jms.MessageProducer; +import javax.jms.Session; +import javax.jms.TextMessage; + +/** + * @author <a href="mailto:bill@burkecentral.com">Bill Burke</a> + * @version $Revision: 1 $ + */ +public class MessageSender +{ + private ConnectionFactory connectionFactory; + private Destination destination; + + public ConnectionFactory getConnectionFactory() + { + return connectionFactory; + } + + public void setConnectionFactory(ConnectionFactory connectionFactory) + { + this.connectionFactory = connectionFactory; + } + + public Destination getDestination() + { + return destination; + } + + public void setDestination(Destination destination) + { + this.destination = destination; + } + + public void send(String msg) + { + try + { + Connection conn = connectionFactory.createConnection(); + Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + MessageProducer producer = session.createProducer(destination); + TextMessage message = session.createTextMessage(msg); + producer.send(message); + } + catch (Exception ex) + { + ex.printStackTrace(); + } + } +} Added: trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/SpringExample.java =================================================================== --- trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/SpringExample.java (rev 0) +++ trunk/examples/jms/spring-integration/src/org/hornetq/jms/example/SpringExample.java 2010-09-02 23:21:38 UTC (rev 9631) @@ -0,0 +1,22 @@ +package org.hornetq.jms.example; + +import org.springframework.context.ApplicationContext; +import org.springframework.context.support.ClassPathXmlApplicationContext; + +/** + * @author <a href="mailto:bill@burkecentral.com">Bill Burke</a> + * @version $Revision: 1 $ + */ +public class SpringExample +{ + public static void main(String[] args) throws Exception + { + System.out.println("Creating bean factory..."); + ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"spring-jms-beans.xml"}); + MessageSender sender = (MessageSender)context.getBean("MessageSender"); + System.out.println("Sending message..."); + sender.send("Hello world"); + Thread.sleep(100); + context.destroy(); + } +} Modified: trunk/src/main/org/hornetq/core/registry/MapBindingRegistry.java =================================================================== --- trunk/src/main/org/hornetq/core/registry/MapBindingRegistry.java 2010-09-02 23:20:36 UTC (rev 9630) +++ trunk/src/main/org/hornetq/core/registry/MapBindingRegistry.java 2010-09-02 23:21:38 UTC (rev 9631) @@ -1,7 +1,7 @@ package org.hornetq.core.registry; import org.hornetq.spi.BindingRegistry; -import org.jboss.netty.util.internal.ConcurrentHashMap; +import java.util.concurrent.ConcurrentHashMap; /** * @author <a href="mailto:bill@burkecentral.com">Bill Burke</a> Modified: trunk/src/main/org/hornetq/core/server/embedded/EmbeddedHornetQ.java =================================================================== --- trunk/src/main/org/hornetq/core/server/embedded/EmbeddedHornetQ.java 2010-09-02 23:20:36 UTC (rev 9630) +++ trunk/src/main/org/hornetq/core/server/embedded/EmbeddedHornetQ.java 2010-09-02 23:21:38 UTC (rev 9631) @@ -1,5 +1,6 @@ package org.hornetq.core.server.embedded; +import org.hornetq.core.config.Configuration; import org.hornetq.core.config.impl.FileConfiguration; import org.hornetq.core.server.HornetQServer; import org.hornetq.core.server.impl.HornetQServerImpl; @@ -17,7 +18,8 @@ public class EmbeddedHornetQ { protected HornetQSecurityManager securityManager; - protected FileConfiguration configuration = new FileConfiguration(); + protected String configResourcePath = null; + protected Configuration configuration; protected HornetQServer hornetQServer; protected MBeanServer mbeanServer; @@ -28,7 +30,7 @@ */ public void setConfigResourcePath(String filename) { - configuration.setConfigurationUrl(filename); + configResourcePath = filename; } /** @@ -51,6 +53,17 @@ this.mbeanServer = mbeanServer; } + /** + * Set this object if you are not using file-based configuration. The default implementation will load + * configuration from a file. + * + * @param configuration + */ + public void setConfiguration(Configuration configuration) + { + this.configuration = configuration; + } + public HornetQServer getHornetQServer() { return hornetQServer; @@ -65,7 +78,14 @@ protected void initStart() throws Exception { - configuration.start(); + if (configuration == null) + { + if (configResourcePath == null) configResourcePath = "hornetq-configuration.xml"; + FileConfiguration config = new FileConfiguration(); + config.setConfigurationUrl(configResourcePath); + config.start(); + configuration = config; + } if (securityManager == null) { securityManager = new HornetQSecurityManagerImpl(); Modified: trunk/src/main/org/hornetq/jms/server/embedded/EmbeddedJMS.java =================================================================== --- trunk/src/main/org/hornetq/jms/server/embedded/EmbeddedJMS.java 2010-09-02 23:20:36 UTC (rev 9630) +++ trunk/src/main/org/hornetq/jms/server/embedded/EmbeddedJMS.java 2010-09-02 23:21:38 UTC (rev 9631) @@ -1,16 +1,20 @@ package org.hornetq.jms.server.embedded; +import org.hornetq.core.registry.JndiBindingRegistry; import org.hornetq.core.registry.MapBindingRegistry; import org.hornetq.core.server.embedded.EmbeddedHornetQ; +import org.hornetq.jms.server.config.JMSConfiguration; import org.hornetq.jms.server.impl.JMSServerManagerImpl; import org.hornetq.spi.BindingRegistry; +import javax.naming.Context; + /** * Simple bootstrap class that parses hornetq config files (server and jms and security) and starts * a HornetQServer instance and populates it with configured JMS endpoints. * <p/> * JMS Endpoints are registered with a simple MapBindingRegistry. If you want to use a different registry - * you must set the registry property of this clas + * you must set the registry property of this class or call the setRegistry() method if you want to use JNDI * * @author <a href="mailto:bill@burkecentral.com">Bill Burke</a> * @version $Revision: 1 $ @@ -20,6 +24,8 @@ protected JMSServerManagerImpl serverManager; protected BindingRegistry registry; protected String jmsConfigResourcePath; + protected JMSConfiguration jmsConfiguration; + protected Context context; /** * Classpath resource where JMS config file is. Defaults to 'hornetq-jms.xml' @@ -36,12 +42,37 @@ return registry; } + /** + * Only set this property if you are using a custom BindingRegistry + * + * @param registry + */ public void setRegistry(BindingRegistry registry) { this.registry = registry; } /** + * By default, this class uses file-based configuration. Set this property to override it. + * + * @param jmsConfiguration + */ + public void setJmsConfiguration(JMSConfiguration jmsConfiguration) + { + this.jmsConfiguration = jmsConfiguration; + } + + /** + * If you want to use JNDI instead of an internal map, set this property + * + * @param context + */ + public void setContext(Context context) + { + this.context = context; + } + + /** * Lookup in the registry for registered object, i.e. a ConnectionFactory. This is a convenience method. * * @param name @@ -55,11 +86,17 @@ public void start() throws Exception { super.initStart(); - if (jmsConfigResourcePath == null) serverManager = new JMSServerManagerImpl(hornetQServer); + if (jmsConfiguration != null) + { + serverManager = new JMSServerManagerImpl(hornetQServer, jmsConfiguration); + } + else if (jmsConfigResourcePath == null) serverManager = new JMSServerManagerImpl(hornetQServer); else serverManager = new JMSServerManagerImpl(hornetQServer, jmsConfigResourcePath); + if (registry == null) { - registry = new MapBindingRegistry(); + if (context != null) registry = new JndiBindingRegistry(context); + else registry = new MapBindingRegistry(); } serverManager.setRegistry(registry); serverManager.start();