[jboss-cvs] JBoss Messaging SVN: r7347 - in trunk/examples/jms/embedded: src/org/jboss/jms/example and 1 other directory.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Mon Jun 15 12:11:50 EDT 2009
Author: clebert.suconic at jboss.com
Date: 2009-06-15 12:11:50 -0400 (Mon, 15 Jun 2009)
New Revision: 7347
Modified:
trunk/examples/jms/embedded/readme.html
trunk/examples/jms/embedded/src/org/jboss/jms/example/EmbeddedExample.java
Log:
Fixing embedded example (InVM acceptor is not available by default any more)
Modified: trunk/examples/jms/embedded/readme.html
===================================================================
--- trunk/examples/jms/embedded/readme.html 2009-06-15 15:33:09 UTC (rev 7346)
+++ trunk/examples/jms/embedded/readme.html 2009-06-15 16:11:50 UTC (rev 7347)
@@ -21,7 +21,8 @@
<pre>
<code>Configuration configuration = new ConfigurationImpl();</code>
<code>configuration.setEnablePersistence(false);</code>
- <code>configuration.setSecurityEnabled(false);</code></pre>
+ <code>configuration.setSecurityEnabled(false);</code>
+ <code>configuration.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getName()));</code></pre>
<li>Create and start the server</li>
<pre>
Modified: trunk/examples/jms/embedded/src/org/jboss/jms/example/EmbeddedExample.java
===================================================================
--- trunk/examples/jms/embedded/src/org/jboss/jms/example/EmbeddedExample.java 2009-06-15 15:33:09 UTC (rev 7346)
+++ trunk/examples/jms/embedded/src/org/jboss/jms/example/EmbeddedExample.java 2009-06-15 16:11:50 UTC (rev 7347)
@@ -34,6 +34,7 @@
import org.jboss.messaging.core.config.Configuration;
import org.jboss.messaging.core.config.TransportConfiguration;
import org.jboss.messaging.core.config.impl.ConfigurationImpl;
+import org.jboss.messaging.core.remoting.impl.invm.InVMAcceptorFactory;
import org.jboss.messaging.core.remoting.impl.invm.InVMConnectorFactory;
import org.jboss.messaging.core.server.Messaging;
import org.jboss.messaging.core.server.MessagingServer;
@@ -57,6 +58,7 @@
Configuration configuration = new ConfigurationImpl();
configuration.setPersistenceEnabled(false);
configuration.setSecurityEnabled(false);
+ configuration.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getName()));
// Step 2. Create and start the server
MessagingServer server = Messaging.newMessagingServer(configuration);
More information about the jboss-cvs-commits
mailing list