[jboss-cvs] JBoss Messaging SVN: r4779 - trunk/examples/messaging/src/org/jboss/messaging/example.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Thu Aug 7 04:32:52 EDT 2008


Author: jmesnil
Date: 2008-08-07 04:32:51 -0400 (Thu, 07 Aug 2008)
New Revision: 4779

Modified:
   trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java
Log:
fixed example, added missing MinaAcceptorFactory registration

Modified: trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java
===================================================================
--- trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java	2008-08-06 23:08:57 UTC (rev 4778)
+++ trunk/examples/messaging/src/org/jboss/messaging/example/SimpleExample.java	2008-08-07 08:32:51 UTC (rev 4779)
@@ -29,6 +29,7 @@
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.message.Message;
 import org.jboss.messaging.core.remoting.TransportType;
+import org.jboss.messaging.core.remoting.impl.mina.MinaAcceptorFactory;
 import org.jboss.messaging.core.server.MessagingService;
 import org.jboss.messaging.core.server.impl.MessagingServiceImpl;
 import org.jboss.messaging.jms.client.JBossTextMessage;
@@ -52,7 +53,9 @@
          ConfigurationImpl configuration = new ConfigurationImpl();
          configuration.setTransport(TransportType.TCP);
          configuration.setHost("localhost");
+         configuration.setSecurityEnabled(false);
          messagingService = MessagingServiceImpl.newNullStorageMessagingServer(configuration);
+         messagingService.getServer().getRemotingService().registerAcceptorFactory(new MinaAcceptorFactory());      
          //start the server
          messagingService.start();
 




More information about the jboss-cvs-commits mailing list