[jboss-cvs] JBoss Messaging SVN: r7220 - trunk/tests/src/org/jboss/messaging/tests/integration/http.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2009-06-05 07:03:45 -0400 (Fri, 05 Jun 2009)
New Revision: 7220

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/http/CoreClientOverHttpTest.java
Log:
uncommented CoreClientOverHttpTest tests

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/http/CoreClientOverHttpTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/http/CoreClientOverHttpTest.java	2009-06-05 09:55:59 UTC (rev 7219)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/http/CoreClientOverHttpTest.java	2009-06-05 11:03:45 UTC (rev 7220)
@@ -43,91 +43,86 @@
  */
 public class CoreClientOverHttpTest extends UnitTestCase
 {
-//   public void testCoreHttpClient() throws Exception
-//   {
-//      final SimpleString QUEUE = new SimpleString("CoreClientOverHttpTestQueue");
-//
-//      Configuration conf = new ConfigurationImpl();
-//
-//      conf.setSecurityEnabled(false);
-//
-//      HashMap<String, Object> params = new HashMap<String, Object>();
-//      params.put("jbm.remoting.netty.httpenabled", true);
-//      conf.getAcceptorConfigurations().add(new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, params));
-//
-//      MessagingServer server = Messaging.newNullStorageMessagingServer(conf);
-//
-//      server.start();
-//
-//      ClientSessionFactory sf = new ClientSessionFactoryImpl(new TransportConfiguration(NETTY_CONNECTOR_FACTORY, params));
-//
-//      ClientSession session = sf.createSession(false, true, true);
-//
-//      session.createQueue(QUEUE, QUEUE, null, false, false);
-//      
-//      ClientProducer producer = session.createProducer(QUEUE);
-//
-//      final int numMessages = 100;
-//
-//      for (int i = 0; i < numMessages; i++)
-//      {
-//         ClientMessage message = session.createClientMessage(JBossTextMessage.TYPE, false, 0,
-//               System.currentTimeMillis(), (byte) 1);
-//         message.getBody().writeString("CoreClientOverHttpTest");
-//         producer.send(message);
-//      }
-//
-//      ClientConsumer consumer = session.createConsumer(QUEUE);
-//
-//      session.start();
-//
-//      for (int i = 0; i < numMessages; i++)
-//      {
-//         ClientMessage message2 = consumer.receive();
-//
-//         assertEquals("CoreClientOverHttpTest", message2.getBody().readString());
-//
-//         message2.acknowledge();
-//      }
-//
-//      session.close();
-//
-//      server.stop();
-//   }
-//
-//   public void testCoreHttpClientIdle() throws Exception
-//   {
-//      final SimpleString QUEUE = new SimpleString("CoreClientOverHttpTestQueue");
-//
-//      Configuration conf = new ConfigurationImpl();
-//
-//      conf.setSecurityEnabled(false);
-//
-//      HashMap<String, Object> params = new HashMap<String, Object>();
-//      params.put("jbm.remoting.netty.httpenabled", true);
-//      conf.getAcceptorConfigurations().add(new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, params));
-//
-//      MessagingServer server = Messaging.newNullStorageMessagingServer(conf);
-//
-//      server.start();
-//
-//      ClientSessionFactory sf = new ClientSessionFactoryImpl(new TransportConfiguration(NETTY_CONNECTOR_FACTORY, params));
-//
-//      ClientSession session = sf.createSession(false, true, true);
-//
-//      session.createQueue(QUEUE, QUEUE, null, false, false);
-//
-//      ClientProducer producer = session.createProducer(QUEUE);
-//
-//      Thread.sleep(server.getServer().getConfiguration().getConnectionScanPeriod() * 5);
-//
-//      session.close();
-//
-//      server.stop();
-//   }
-   
-   public void testFoo()
+   public void testCoreHttpClient() throws Exception
    {
+      final SimpleString QUEUE = new SimpleString("CoreClientOverHttpTestQueue");
+
+      Configuration conf = new ConfigurationImpl();
+
+      conf.setSecurityEnabled(false);
+
+      HashMap<String, Object> params = new HashMap<String, Object>();
+      params.put("jbm.remoting.netty.httpenabled", true);
+      conf.getAcceptorConfigurations().add(new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, params));
+
+      MessagingServer server = Messaging.newMessagingServer(conf, false);
       
+      server.start();
+
+      ClientSessionFactory sf = new ClientSessionFactoryImpl(new TransportConfiguration(NETTY_CONNECTOR_FACTORY, params));
+
+      ClientSession session = sf.createSession(false, true, true);
+
+      session.createQueue(QUEUE, QUEUE, null, false);
+      
+      ClientProducer producer = session.createProducer(QUEUE);
+
+      final int numMessages = 100;
+
+      for (int i = 0; i < numMessages; i++)
+      {
+         ClientMessage message = session.createClientMessage(JBossTextMessage.TYPE, false, 0,
+               System.currentTimeMillis(), (byte) 1);
+         message.getBody().writeString("CoreClientOverHttpTest");
+         producer.send(message);
+      }
+
+      ClientConsumer consumer = session.createConsumer(QUEUE);
+
+      session.start();
+
+      for (int i = 0; i < numMessages; i++)
+      {
+         ClientMessage message2 = consumer.receive();
+
+         assertEquals("CoreClientOverHttpTest", message2.getBody().readString());
+
+         message2.acknowledge();
+      }
+
+      session.close();
+
+      server.stop();
    }
+
+   public void testCoreHttpClientIdle() throws Exception
+   {
+      final SimpleString QUEUE = new SimpleString("CoreClientOverHttpTestQueue");
+
+      Configuration conf = new ConfigurationImpl();
+
+      conf.setSecurityEnabled(false);
+
+      HashMap<String, Object> params = new HashMap<String, Object>();
+      params.put("jbm.remoting.netty.httpenabled", true);
+      conf.getAcceptorConfigurations().add(new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, params));
+
+      MessagingServer server = Messaging.newMessagingServer(conf, false);
+      
+      server.start();
+
+      ClientSessionFactory sf = new ClientSessionFactoryImpl(new TransportConfiguration(NETTY_CONNECTOR_FACTORY, params));
+
+      ClientSession session = sf.createSession(false, true, true);
+
+      session.createQueue(QUEUE, QUEUE, null, false);
+
+      ClientProducer producer = session.createProducer(QUEUE);
+
+      Thread.sleep(server.getConfiguration().getConnectionScanPeriod() * 5);
+
+      session.close();
+
+      server.stop();
+   }   
 }