[jboss-cvs] JBoss Messaging SVN: r7575 - trunk/tests/src/org/jboss/messaging/tests/unit/core/filter/impl.

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

Author: jmesnil
Date: 2009-07-15 09:24:00 -0400 (Wed, 15 Jul 2009)
New Revision: 7575

Modified:
   trunk/tests/src/org/jboss/messaging/tests/unit/core/filter/impl/FilterTest.java
Log:
JBMESSAGING-1575: Add test for message size in selector and remove message id

* added FilterTest::testJBMSize
* Message ID was already removed from FilterImpl headers 

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/filter/impl/FilterTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/filter/impl/FilterTest.java	2009-07-15 12:38:12 UTC (rev 7574)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/filter/impl/FilterTest.java	2009-07-15 13:24:00 UTC (rev 7575)
@@ -22,11 +22,13 @@
 
 package org.jboss.messaging.tests.unit.core.filter.impl;
 
+import org.jboss.messaging.core.buffers.ChannelBuffers;
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.filter.Filter;
 import org.jboss.messaging.core.filter.impl.FilterImpl;
 import org.jboss.messaging.core.server.ServerMessage;
 import org.jboss.messaging.core.server.impl.ServerMessageImpl;
+import org.jboss.messaging.tests.util.RandomUtil;
 import org.jboss.messaging.tests.util.UnitTestCase;
 import org.jboss.messaging.utils.SimpleString;
 
@@ -96,7 +98,26 @@
       assertTrue(filter.match(message));
       
    }
+   
+   public void testJBMSize() throws Exception
+   {
+      message.setDestination(RandomUtil.randomSimpleString());      
+      message.setBody(ChannelBuffers.wrappedBuffer(RandomUtil.randomBytes(1)));
+      assertTrue(message.getEncodeSize() < 1024);
+      
+      Filter moreThan128 = new FilterImpl(new SimpleString("JBMSize > 128"));
+      Filter lessThan1024 = new FilterImpl(new SimpleString("JBMSize < 1024"));
+      
+      assertFalse(moreThan128.match(message));
+      assertTrue(lessThan1024.match(message));
+      
+      message.setBody(ChannelBuffers.wrappedBuffer(RandomUtil.randomBytes(1024)));
 
+      assertTrue(moreThan128.match(message));
+      assertFalse(lessThan1024.match(message));
+
+   }
+
    public void testJBMPriority() throws Exception
    {
       filter = new FilterImpl(new SimpleString("JBMPriority=3"));