[jboss-cvs] JBoss Messaging SVN: r4610 - trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/mina.

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

Author: jmesnil
Date: 2008-06-27 09:32:13 -0400 (Fri, 27 Jun 2008)
New Revision: 4610

Modified:
   trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/mina/MinaProtocolCodecFilterTest.java
Log:
added testEncode()

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/mina/MinaProtocolCodecFilterTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/mina/MinaProtocolCodecFilterTest.java	2008-06-27 09:57:39 UTC (rev 4609)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/mina/MinaProtocolCodecFilterTest.java	2008-06-27 13:32:13 UTC (rev 4610)
@@ -22,6 +22,10 @@
 
 package org.jboss.messaging.tests.unit.core.remoting.impl.mina;
 
+import static org.easymock.EasyMock.createStrictMock;
+import static org.easymock.EasyMock.isA;
+import static org.easymock.EasyMock.replay;
+import static org.easymock.EasyMock.verify;
 import static org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl.CLOSE;
 import static org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl.CONN_CREATESESSION;
 import static org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl.CONN_CREATESESSION_RESP;
@@ -88,7 +92,10 @@
 import javax.transaction.xa.Xid;
 
 import org.apache.mina.common.IoBuffer;
+import org.apache.mina.common.IoSession;
 import org.apache.mina.filter.codec.ProtocolDecoderOutput;
+import org.apache.mina.filter.codec.ProtocolEncoderOutput;
+import org.easymock.EasyMock;
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.logging.Logger;
 import org.jboss.messaging.core.remoting.Packet;
@@ -288,6 +295,21 @@
 
    // Public --------------------------------------------------------
 
+   public void testEncode() throws Exception
+   {
+      IoSession session = createStrictMock(IoSession.class);
+      Object message = new PacketImpl(NULL);
+      ProtocolEncoderOutput out = createStrictMock(ProtocolEncoderOutput.class);
+
+      out.write(isA(IoBuffer.class));
+      replay(session, out);
+
+      MinaProtocolCodecFilter filter = new MinaProtocolCodecFilter();
+      filter.encode(session, message, out);
+      
+      verify(session, out);
+   }
+   
    public void testNullPacket() throws Exception
    {
       Packet packet = new PacketImpl(NULL);