[jboss-cvs] JBoss Messaging SVN: r3313 - projects/jbm-mina/tests/src/org/jboss/messaging/remoting.

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

Author: jmesnil
Date: 2007-11-12 08:52:16 -0500 (Mon, 12 Nov 2007)
New Revision: 3313

Added:
   projects/jbm-mina/tests/src/org/jboss/messaging/remoting/SecurityTest.java
Log:
* test SSL on top of both TCP & HTTP

Added: projects/jbm-mina/tests/src/org/jboss/messaging/remoting/SecurityTest.java
===================================================================
--- projects/jbm-mina/tests/src/org/jboss/messaging/remoting/SecurityTest.java	                        (rev 0)
+++ projects/jbm-mina/tests/src/org/jboss/messaging/remoting/SecurityTest.java	2007-11-12 13:52:16 UTC (rev 3313)
@@ -0,0 +1,78 @@
+package org.jboss.messaging.remoting;
+
+import static org.jboss.messaging.remoting.internal.Constants.PORT;
+import static org.jboss.messaging.remoting.internal.TransportType.HTTP;
+import static org.jboss.messaging.remoting.internal.TransportType.TCP;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.util.List;
+
+import org.jboss.messaging.remoting.internal.TransportType;
+import org.jboss.messaging.remoting.wireformat.AbstractPacket;
+import org.jboss.messaging.remoting.wireformat.TextPacket;
+import org.junit.After;
+import org.junit.Test;
+
+
+public class SecurityTest extends TestSupport
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   // Public --------------------------------------------------------
+
+   public void setUp(TransportType transport) throws Exception
+   {
+      startServer(PORT, transport, true);
+      startClient(PORT, transport, true);
+   }
+
+   @After
+   public void tearDown() throws Exception
+   {
+      assertTrue(clientDispatcher.disconnect());
+      serverAcceptor.unbind();
+   }
+
+   public void sendUsingTransport(TransportType transport, String text)
+         throws Exception
+   {
+      setUp(transport);
+
+      TextPacket packet = new TextPacket(text);
+      clientDispatcher.sendOneWay(packet);
+
+      Thread.sleep(300);
+
+      List<AbstractPacket> messages = serverHandler.getPackets();
+      assertEquals(1, messages.size());
+      String response = ((TextPacket) messages.get(0)).getText();
+      assertEquals(packet.getText(), response);
+   }
+
+   @Test
+   public void testSSLOverTCP() throws Exception
+   {
+      sendUsingTransport(TCP, "testSSLOverTCP");
+   }
+
+   @Test
+   public void testSSLOverHTTP() throws Exception
+   {
+      sendUsingTransport(HTTP, "testSSLOverHTTP");
+   }
+   
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}