[jboss-cvs] JBoss Messaging SVN: r3399 - branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal.

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

Author: jmesnil
Date: 2007-12-03 09:35:33 -0500 (Mon, 03 Dec 2007)
New Revision: 3399

Added:
   branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal/MinaHandlerTest.java
   branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal/MinaInspectorTest.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-544 Replace client-server transport with NIO based transport
* refactoring

Added: branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal/MinaHandlerTest.java
===================================================================
--- branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal/MinaHandlerTest.java	                        (rev 0)
+++ branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal/MinaHandlerTest.java	2007-12-03 14:35:33 UTC (rev 3399)
@@ -0,0 +1,98 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.test.messaging.core.remoting.internal;
+
+import junit.framework.TestCase;
+
+import org.jboss.messaging.core.remoting.PacketDispatcher;
+import org.jboss.messaging.core.remoting.internal.MinaHandler;
+import org.jboss.messaging.core.remoting.wireformat.TextPacket;
+import org.jboss.test.messaging.core.remoting.TestPacketHandler;
+
+/**
+ * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
+ * 
+ * @version <tt>$Revision$</tt>
+ * 
+ */
+public class MinaHandlerTest extends TestCase
+{
+
+   private MinaHandler handler;
+   private TestPacketHandler packetHandler;
+
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   // Public --------------------------------------------------------
+
+   public void testReceiveNotAbstractPacket() throws Exception
+   {
+      try
+      {
+         handler.messageReceived(null, new Object());
+         fail();
+      } catch (IllegalArgumentException e)
+      {
+      }
+   }
+
+   public void testReceiveUnhandledAbstractPacket() throws Exception
+   {
+      TextPacket packet = new TextPacket("testReceiveUnhandledAbstractPacket");
+
+      handler.messageReceived(null, packet);
+
+      assertEquals(0, packetHandler.getPackets().size());
+   }
+
+   public void testReceiveHandledAbstractPacket() throws Exception
+   {
+
+      TextPacket packet = new TextPacket("testReceiveHandledAbstractPacket");
+      packet.setTargetID(packetHandler.getID());
+
+      handler.messageReceived(null, packet);
+
+      assertEquals(1, packetHandler.getPackets().size());
+      assertEquals(packet.getText(), packetHandler.getPackets().get(0)
+            .getText());
+   }
+
+   // TestCase overrides --------------------------------------------
+
+   @Override
+   protected void setUp() throws Exception
+   {
+      handler = new MinaHandler(PacketDispatcher.client);
+
+      packetHandler = new TestPacketHandler();
+      PacketDispatcher.client.register(packetHandler);
+   }
+
+   @Override
+   protected void tearDown() throws Exception
+   {
+      PacketDispatcher.client.unregister(packetHandler.getID());
+      packetHandler = null;
+
+      handler = null;
+   }
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}

Added: branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal/MinaInspectorTest.java
===================================================================
--- branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal/MinaInspectorTest.java	                        (rev 0)
+++ branches/Branch_JBMESSAGING-544/tests/src/org/jboss/test/messaging/core/remoting/internal/MinaInspectorTest.java	2007-12-03 14:35:33 UTC (rev 3399)
@@ -0,0 +1,109 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.test.messaging.core.remoting.internal;
+
+import static org.apache.mina.filter.reqres.ResponseType.WHOLE;
+
+import java.util.UUID;
+
+import junit.framework.TestCase;
+
+import org.jboss.messaging.core.remoting.internal.MinaInspector;
+import org.jboss.messaging.core.remoting.wireformat.AbstractPacket;
+import org.jboss.messaging.core.remoting.wireformat.NullPacket;
+
+/**
+ * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
+ * 
+ * @version <tt>$Revision$</tt>
+ * 
+ */
+public class MinaInspectorTest extends TestCase
+{
+
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   // Public --------------------------------------------------------
+
+   private MinaInspector inspector;
+
+   public void testGetRequestIdForNull()
+   {
+      assertNull(inspector.getRequestId(null));
+   }
+
+   public void testGetRequestIdForNotAbstractPacket()
+   {
+      assertNull(inspector.getRequestId(new Object()));
+   }
+
+   public void testGetRequestIdForAbstractPacketWhichIsNotRequest()
+   {
+      AbstractPacket packet = new NullPacket();
+      packet.setTargetID(UUID.randomUUID().toString());
+      assertFalse(packet.isRequest());
+
+      assertNull(inspector.getRequestId(packet));
+   }
+
+   public void testGetRequestIdForAbstractPacketWhichIsRequest()
+   {
+      AbstractPacket packet = new NullPacket();
+      packet.setTargetID(UUID.randomUUID().toString());
+      packet.setCorrelationID(System.currentTimeMillis());
+      assertTrue(packet.isRequest());
+
+      Object requestID = inspector.getRequestId(packet);
+      assertNotNull(requestID);
+      assertEquals(packet.getCorrelationID(), requestID);
+   }
+
+   public void testGetResponseTypeForNull()
+   {
+      assertNull(inspector.getResponseType(null));
+   }
+
+   public void testGetResponseTypeForNotAbstractPacket()
+   {
+      assertNull(inspector.getResponseType(new Object()));
+   }
+
+   public void testGetResponseTypeForAbstractPacket()
+   {
+      AbstractPacket packet = new NullPacket();
+
+      assertEquals(WHOLE, inspector.getResponseType(packet));
+   }
+
+   // TestCase overrides --------------------------------------------
+
+   @Override
+   protected void setUp() throws Exception
+   {
+      inspector = new MinaInspector();
+   }
+
+   @Override
+   protected void tearDown() throws Exception
+   {
+      inspector = null;
+   }
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}