[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