[hornetq-commits] JBoss hornetq SVN: r8132 - trunk/tests/src/org/hornetq/tests/unit/core/message/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Wed Oct 21 05:11:47 EDT 2009
Author: jmesnil
Date: 2009-10-21 05:11:46 -0400 (Wed, 21 Oct 2009)
New Revision: 8132
Added:
trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTest.java
Removed:
trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTestBase.java
Log:
Core Message unit tests
* renamed MessageImplTestBase to MessageImplTest and made it concrete
Copied: trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTest.java (from rev 8128, trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTestBase.java)
===================================================================
--- trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTest.java (rev 0)
+++ trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTest.java 2009-10-21 09:11:46 UTC (rev 8132)
@@ -0,0 +1,343 @@
+/*
+ * Copyright 2009 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied. See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.hornetq.tests.unit.core.message.impl;
+
+import static org.hornetq.tests.util.RandomUtil.randomBoolean;
+import static org.hornetq.tests.util.RandomUtil.randomByte;
+import static org.hornetq.tests.util.RandomUtil.randomBytes;
+import static org.hornetq.tests.util.RandomUtil.randomDouble;
+import static org.hornetq.tests.util.RandomUtil.randomFloat;
+import static org.hornetq.tests.util.RandomUtil.randomInt;
+import static org.hornetq.tests.util.RandomUtil.randomLong;
+import static org.hornetq.tests.util.RandomUtil.randomShort;
+import static org.hornetq.tests.util.RandomUtil.randomString;
+
+import java.util.Set;
+
+import org.hornetq.core.buffers.ChannelBuffers;
+import org.hornetq.core.client.impl.ClientMessageImpl;
+import org.hornetq.core.journal.EncodingSupport;
+import org.hornetq.core.logging.Logger;
+import org.hornetq.core.message.Message;
+import org.hornetq.core.remoting.spi.HornetQBuffer;
+import org.hornetq.core.server.impl.ServerMessageImpl;
+import org.hornetq.tests.util.UnitTestCase;
+import org.hornetq.utils.SimpleString;
+
+/**
+ *
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ *
+ */
+public class MessageImplTest extends UnitTestCase
+{
+ private static final Logger log = Logger.getLogger(MessageImplTest.class);
+
+ public void testEncodeDecode()
+ {
+ for (int j = 0; j < 10; j++)
+ {
+ byte[] bytes = new byte[1000];
+ for (int i = 0; i < bytes.length; i++)
+ {
+ bytes[i] = randomByte();
+ }
+ HornetQBuffer body = ChannelBuffers.wrappedBuffer(bytes);
+ Message message1 = new ClientMessageImpl(randomByte(), randomBoolean(), randomLong(), randomLong(), randomByte(), body);
+ Message message = message1;
+ message.setDestination(new SimpleString("oasoas"));
+
+ message.putStringProperty(new SimpleString("prop1"), new SimpleString("blah1"));
+ message.putStringProperty(new SimpleString("prop2"), new SimpleString("blah2"));
+ HornetQBuffer buffer = ChannelBuffers.buffer(message.getEncodeSize());
+ message.encode(buffer);
+ Message message2 = new ClientMessageImpl(false);
+ message2.decode(buffer);
+ assertMessagesEquivalent(message, message2);
+ }
+ }
+
+ public void getSetAttributes()
+ {
+ for (int j = 0; j < 10; j++)
+ {
+ byte[] bytes = new byte[1000];
+ for (int i = 0; i < bytes.length; i++)
+ {
+ bytes[i] = randomByte();
+ }
+ HornetQBuffer body = ChannelBuffers.wrappedBuffer(bytes);
+
+ final byte type = randomByte();
+ final boolean durable = randomBoolean();
+ final long expiration = randomLong();
+ final long timestamp = randomLong();
+ final byte priority = randomByte();
+ Message message1 = new ClientMessageImpl(type, durable, expiration, timestamp, priority, body);
+
+ Message message = message1;
+
+ assertEquals(type, message.getType());
+ assertEquals(durable, message.isDurable());
+ assertEquals(expiration, message.getExpiration());
+ assertEquals(timestamp, message.getTimestamp());
+ assertEquals(priority, message.getPriority());
+
+ final SimpleString destination = new SimpleString(randomString());
+ final boolean durable2 = randomBoolean();
+ final long expiration2 = randomLong();
+ final long timestamp2 = randomLong();
+ final byte priority2 = randomByte();
+
+ message.setDestination(destination);
+ assertEquals(destination, message.getDestination());
+
+ message.setDurable(durable2);
+ assertEquals(durable2, message.isDurable());
+
+ message.setExpiration(expiration2);
+ assertEquals(expiration2, message.getExpiration());
+
+ message.setTimestamp(timestamp2);
+ assertEquals(timestamp2, message.getTimestamp());
+
+ message.setPriority(priority2);
+ assertEquals(priority2, message.getPriority());
+
+ message.setBody(body);
+ assertTrue(body == message.getBody());
+ }
+ }
+
+ public void testExpired()
+ {
+ Message message = new ClientMessageImpl(false);
+
+ assertEquals(0, message.getExpiration());
+ assertFalse(message.isExpired());
+
+ message.setExpiration(System.currentTimeMillis() + 1000);
+ assertFalse(message.isExpired());
+
+ message.setExpiration(System.currentTimeMillis() - 1);
+ assertTrue(message.isExpired());
+
+ message.setExpiration(System.currentTimeMillis() - 1000);
+ assertTrue(message.isExpired());
+
+ message.setExpiration(0);
+ assertFalse(message.isExpired());
+ }
+
+
+ public void testEncodingMessage() throws Exception
+ {
+
+ SimpleString address = new SimpleString("Simple Destination ");
+
+ Message msg = new ClientMessageImpl(false);
+
+ byte[] bytes = new byte[]{(byte)1, (byte)2, (byte)3};
+ msg.setBody(ChannelBuffers.wrappedBuffer(bytes));
+
+ msg.setDestination(address);
+ msg.putStringProperty(new SimpleString("Key"), new SimpleString("This String is worthless!"));
+ msg.putStringProperty(new SimpleString("Key"), new SimpleString("This String is worthless and bigger!"));
+ msg.putStringProperty(new SimpleString("Key2"), new SimpleString("This String is worthless and bigger and bigger!"));
+ msg.removeProperty(new SimpleString("Key2"));
+
+ checkSizes(msg, new ServerMessageImpl());
+
+ msg.removeProperty(new SimpleString("Key"));
+
+ checkSizes(msg, new ServerMessageImpl());
+ }
+
+ public void testProperties()
+ {
+ for (int j = 0; j < 10; j++)
+ {
+ Message msg = new ClientMessageImpl(false);
+
+ SimpleString prop1 = new SimpleString("prop1");
+ boolean val1 = randomBoolean();
+ msg.putBooleanProperty(prop1, val1);
+
+ SimpleString prop2 = new SimpleString("prop2");
+ byte val2 = randomByte();
+ msg.putByteProperty(prop2, val2);
+
+ SimpleString prop3 = new SimpleString("prop3");
+ byte[] val3 = randomBytes();
+ msg.putBytesProperty(prop3, val3);
+
+ SimpleString prop4 = new SimpleString("prop4");
+ double val4 = randomDouble();
+ msg.putDoubleProperty(prop4, val4);
+
+ SimpleString prop5 = new SimpleString("prop5");
+ float val5 = randomFloat();
+ msg.putFloatProperty(prop5, val5);
+
+ SimpleString prop6 = new SimpleString("prop6");
+ int val6 = randomInt();
+ msg.putIntProperty(prop6, val6);
+
+ SimpleString prop7 = new SimpleString("prop7");
+ long val7 = randomLong();
+ msg.putLongProperty(prop7, val7);
+
+ SimpleString prop8 = new SimpleString("prop8");
+ short val8 = randomShort();
+ msg.putShortProperty(prop8, val8);
+
+ SimpleString prop9 = new SimpleString("prop9");
+ SimpleString val9 = new SimpleString(randomString());
+ msg.putStringProperty(prop9, val9);
+
+ assertEquals(9, msg.getPropertyNames().size());
+ assertTrue(msg.getPropertyNames().contains(prop1));
+ assertTrue(msg.getPropertyNames().contains(prop2));
+ assertTrue(msg.getPropertyNames().contains(prop3));
+ assertTrue(msg.getPropertyNames().contains(prop4));
+ assertTrue(msg.getPropertyNames().contains(prop5));
+ assertTrue(msg.getPropertyNames().contains(prop6));
+ assertTrue(msg.getPropertyNames().contains(prop7));
+ assertTrue(msg.getPropertyNames().contains(prop8));
+ assertTrue(msg.getPropertyNames().contains(prop9));
+
+ assertTrue(msg.containsProperty(prop1));
+ assertTrue(msg.containsProperty(prop2));
+ assertTrue(msg.containsProperty(prop3));
+ assertTrue(msg.containsProperty(prop4));
+ assertTrue(msg.containsProperty(prop5));
+ assertTrue(msg.containsProperty(prop6));
+ assertTrue(msg.containsProperty(prop7));
+ assertTrue(msg.containsProperty(prop8));
+ assertTrue(msg.containsProperty(prop9));
+
+ assertEquals(val1, msg.getProperty(prop1));
+ assertEquals(val2, msg.getProperty(prop2));
+ assertEquals(val3, msg.getProperty(prop3));
+ assertEquals(val4, msg.getProperty(prop4));
+ assertEquals(val5, msg.getProperty(prop5));
+ assertEquals(val6, msg.getProperty(prop6));
+ assertEquals(val7, msg.getProperty(prop7));
+ assertEquals(val8, msg.getProperty(prop8));
+ assertEquals(val9, msg.getProperty(prop9));
+
+ SimpleString val10 = new SimpleString(randomString());
+ //test overwrite
+ msg.putStringProperty(prop9, val10);
+ assertEquals(val10, msg.getProperty(prop9));
+
+ int val11 = randomInt();
+ msg.putIntProperty(prop9, val11);
+ assertEquals(val11, msg.getProperty(prop9));
+
+ msg.removeProperty(prop1);
+ assertEquals(8, msg.getPropertyNames().size());
+ assertTrue(msg.getPropertyNames().contains(prop2));
+ assertTrue(msg.getPropertyNames().contains(prop3));
+ assertTrue(msg.getPropertyNames().contains(prop4));
+ assertTrue(msg.getPropertyNames().contains(prop5));
+ assertTrue(msg.getPropertyNames().contains(prop6));
+ assertTrue(msg.getPropertyNames().contains(prop7));
+ assertTrue(msg.getPropertyNames().contains(prop8));
+ assertTrue(msg.getPropertyNames().contains(prop9));
+
+ msg.removeProperty(prop2);
+ assertEquals(7, msg.getPropertyNames().size());
+ assertTrue(msg.getPropertyNames().contains(prop3));
+ assertTrue(msg.getPropertyNames().contains(prop4));
+ assertTrue(msg.getPropertyNames().contains(prop5));
+ assertTrue(msg.getPropertyNames().contains(prop6));
+ assertTrue(msg.getPropertyNames().contains(prop7));
+ assertTrue(msg.getPropertyNames().contains(prop8));
+ assertTrue(msg.getPropertyNames().contains(prop9));
+
+ msg.removeProperty(prop9);
+ assertEquals(6, msg.getPropertyNames().size());
+ assertTrue(msg.getPropertyNames().contains(prop3));
+ assertTrue(msg.getPropertyNames().contains(prop4));
+ assertTrue(msg.getPropertyNames().contains(prop5));
+ assertTrue(msg.getPropertyNames().contains(prop6));
+ assertTrue(msg.getPropertyNames().contains(prop7));
+ assertTrue(msg.getPropertyNames().contains(prop8));
+
+ msg.removeProperty(prop3);
+ msg.removeProperty(prop4);
+ msg.removeProperty(prop5);
+ msg.removeProperty(prop6);
+ msg.removeProperty(prop7);
+ msg.removeProperty(prop8);
+ assertEquals(0, msg.getPropertyNames().size());
+ }
+ }
+
+ // Protected -------------------------------------------------------------------------------
+
+ protected void assertMessagesEquivalent(final Message msg1, final Message msg2)
+ {
+ assertEquals(msg1.isDurable(), msg2.isDurable());
+
+ assertEquals(msg1.getExpiration(), msg2.getExpiration());
+
+ assertEquals(msg1.getTimestamp(), msg2.getTimestamp());
+
+ assertEquals(msg1.getPriority(), msg2.getPriority());
+
+ assertEquals(msg1.getType(), msg2.getType());
+
+ assertEqualsByteArrays(msg1.getBody().array(), msg2.getBody().array());
+
+ assertEquals(msg1.getDestination(), msg2.getDestination());
+
+ Set<SimpleString> props1 = msg1.getPropertyNames();
+
+ Set<SimpleString> props2 = msg2.getPropertyNames();
+
+ assertEquals(props1.size(), props2.size());
+
+ for (SimpleString propname: props1)
+ {
+ Object val1 = msg1.getProperty(propname);
+
+ Object val2 = msg2.getProperty(propname);
+
+ assertEquals(val1, val2);
+ }
+ }
+
+ // Private ----------------------------------------------------------------------------------
+
+ private void checkSizes(final Message obj, final EncodingSupport newObject)
+ {
+ HornetQBuffer buffer = ChannelBuffers.buffer(1024);
+ obj.encode(buffer);
+ assertEquals (buffer.writerIndex(), obj.getEncodeSize());
+ int originalSize = buffer.writerIndex();
+
+ buffer.resetReaderIndex();
+ newObject.decode(buffer);
+
+
+ HornetQBuffer newBuffer = ChannelBuffers.buffer(1024);
+
+ newObject.encode(newBuffer);
+
+ assertEquals(newObject.getEncodeSize(), newBuffer.writerIndex());
+ assertEquals(originalSize, newBuffer.writerIndex());
+ }
+}
Deleted: trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTestBase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTestBase.java 2009-10-20 15:54:02 UTC (rev 8131)
+++ trunk/tests/src/org/hornetq/tests/unit/core/message/impl/MessageImplTestBase.java 2009-10-21 09:11:46 UTC (rev 8132)
@@ -1,347 +0,0 @@
-/*
- * Copyright 2009 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied. See the License for the specific language governing
- * permissions and limitations under the License.
- */
-
-package org.hornetq.tests.unit.core.message.impl;
-
-import static org.hornetq.tests.util.RandomUtil.randomBoolean;
-import static org.hornetq.tests.util.RandomUtil.randomByte;
-import static org.hornetq.tests.util.RandomUtil.randomBytes;
-import static org.hornetq.tests.util.RandomUtil.randomDouble;
-import static org.hornetq.tests.util.RandomUtil.randomFloat;
-import static org.hornetq.tests.util.RandomUtil.randomInt;
-import static org.hornetq.tests.util.RandomUtil.randomLong;
-import static org.hornetq.tests.util.RandomUtil.randomShort;
-import static org.hornetq.tests.util.RandomUtil.randomString;
-
-import java.util.Set;
-
-import org.hornetq.core.buffers.ChannelBuffers;
-import org.hornetq.core.journal.EncodingSupport;
-import org.hornetq.core.logging.Logger;
-import org.hornetq.core.message.Message;
-import org.hornetq.core.remoting.spi.HornetQBuffer;
-import org.hornetq.core.server.impl.ServerMessageImpl;
-import org.hornetq.tests.util.UnitTestCase;
-import org.hornetq.utils.SimpleString;
-
-/**
- *
- * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- *
- */
-public abstract class MessageImplTestBase extends UnitTestCase
-{
- private static final Logger log = Logger.getLogger(MessageImplTestBase.class);
-
- protected abstract Message createMessage(final byte type, final boolean durable, final long expiration,
- final long timestamp, final byte priority, HornetQBuffer buffer);
-
- protected abstract Message createMessage();
-
- public void testEncodeDecode()
- {
- for (int j = 0; j < 10; j++)
- {
- byte[] bytes = new byte[1000];
- for (int i = 0; i < bytes.length; i++)
- {
- bytes[i] = randomByte();
- }
- HornetQBuffer body = ChannelBuffers.wrappedBuffer(bytes);
- Message message = createMessage(randomByte(), randomBoolean(), randomLong(),
- randomLong(), randomByte(), body);
- message.setDestination(new SimpleString("oasoas"));
-
- message.putStringProperty(new SimpleString("prop1"), new SimpleString("blah1"));
- message.putStringProperty(new SimpleString("prop2"), new SimpleString("blah2"));
- HornetQBuffer buffer = ChannelBuffers.buffer(message.getEncodeSize());
- message.encode(buffer);
- Message message2 = createMessage();
- message2.decode(buffer);
- assertMessagesEquivalent(message, message2);
- }
- }
-
- public void getSetAttributes()
- {
- for (int j = 0; j < 10; j++)
- {
- byte[] bytes = new byte[1000];
- for (int i = 0; i < bytes.length; i++)
- {
- bytes[i] = randomByte();
- }
- HornetQBuffer body = ChannelBuffers.wrappedBuffer(bytes);
-
- final byte type = randomByte();
- final boolean durable = randomBoolean();
- final long expiration = randomLong();
- final long timestamp = randomLong();
- final byte priority = randomByte();
-
- Message message = createMessage(type, durable, expiration,
- timestamp, priority, body);
-
- assertEquals(type, message.getType());
- assertEquals(durable, message.isDurable());
- assertEquals(expiration, message.getExpiration());
- assertEquals(timestamp, message.getTimestamp());
- assertEquals(priority, message.getPriority());
-
- final SimpleString destination = new SimpleString(randomString());
- final boolean durable2 = randomBoolean();
- final long expiration2 = randomLong();
- final long timestamp2 = randomLong();
- final byte priority2 = randomByte();
-
- message.setDestination(destination);
- assertEquals(destination, message.getDestination());
-
- message.setDurable(durable2);
- assertEquals(durable2, message.isDurable());
-
- message.setExpiration(expiration2);
- assertEquals(expiration2, message.getExpiration());
-
- message.setTimestamp(timestamp2);
- assertEquals(timestamp2, message.getTimestamp());
-
- message.setPriority(priority2);
- assertEquals(priority2, message.getPriority());
-
- message.setBody(body);
- assertTrue(body == message.getBody());
- }
- }
-
- public void testExpired()
- {
- Message message = createMessage();
-
- assertEquals(0, message.getExpiration());
- assertFalse(message.isExpired());
-
- message.setExpiration(System.currentTimeMillis() + 1000);
- assertFalse(message.isExpired());
-
- message.setExpiration(System.currentTimeMillis() - 1);
- assertTrue(message.isExpired());
-
- message.setExpiration(System.currentTimeMillis() - 1000);
- assertTrue(message.isExpired());
-
- message.setExpiration(0);
- assertFalse(message.isExpired());
- }
-
-
- public void testEncodingMessage() throws Exception
- {
-
- SimpleString address = new SimpleString("Simple Destination ");
-
- Message msg = createMessage();
-
- byte[] bytes = new byte[]{(byte)1, (byte)2, (byte)3};
- msg.setBody(ChannelBuffers.wrappedBuffer(bytes));
-
- msg.setDestination(address);
- msg.putStringProperty(new SimpleString("Key"), new SimpleString("This String is worthless!"));
- msg.putStringProperty(new SimpleString("Key"), new SimpleString("This String is worthless and bigger!"));
- msg.putStringProperty(new SimpleString("Key2"), new SimpleString("This String is worthless and bigger and bigger!"));
- msg.removeProperty(new SimpleString("Key2"));
-
- checkSizes(msg, new ServerMessageImpl());
-
- msg.removeProperty(new SimpleString("Key"));
-
- checkSizes(msg, new ServerMessageImpl());
- }
-
- public void testProperties()
- {
- for (int j = 0; j < 10; j++)
- {
- Message msg = createMessage();
-
- SimpleString prop1 = new SimpleString("prop1");
- boolean val1 = randomBoolean();
- msg.putBooleanProperty(prop1, val1);
-
- SimpleString prop2 = new SimpleString("prop2");
- byte val2 = randomByte();
- msg.putByteProperty(prop2, val2);
-
- SimpleString prop3 = new SimpleString("prop3");
- byte[] val3 = randomBytes();
- msg.putBytesProperty(prop3, val3);
-
- SimpleString prop4 = new SimpleString("prop4");
- double val4 = randomDouble();
- msg.putDoubleProperty(prop4, val4);
-
- SimpleString prop5 = new SimpleString("prop5");
- float val5 = randomFloat();
- msg.putFloatProperty(prop5, val5);
-
- SimpleString prop6 = new SimpleString("prop6");
- int val6 = randomInt();
- msg.putIntProperty(prop6, val6);
-
- SimpleString prop7 = new SimpleString("prop7");
- long val7 = randomLong();
- msg.putLongProperty(prop7, val7);
-
- SimpleString prop8 = new SimpleString("prop8");
- short val8 = randomShort();
- msg.putShortProperty(prop8, val8);
-
- SimpleString prop9 = new SimpleString("prop9");
- SimpleString val9 = new SimpleString(randomString());
- msg.putStringProperty(prop9, val9);
-
- assertEquals(9, msg.getPropertyNames().size());
- assertTrue(msg.getPropertyNames().contains(prop1));
- assertTrue(msg.getPropertyNames().contains(prop2));
- assertTrue(msg.getPropertyNames().contains(prop3));
- assertTrue(msg.getPropertyNames().contains(prop4));
- assertTrue(msg.getPropertyNames().contains(prop5));
- assertTrue(msg.getPropertyNames().contains(prop6));
- assertTrue(msg.getPropertyNames().contains(prop7));
- assertTrue(msg.getPropertyNames().contains(prop8));
- assertTrue(msg.getPropertyNames().contains(prop9));
-
- assertTrue(msg.containsProperty(prop1));
- assertTrue(msg.containsProperty(prop2));
- assertTrue(msg.containsProperty(prop3));
- assertTrue(msg.containsProperty(prop4));
- assertTrue(msg.containsProperty(prop5));
- assertTrue(msg.containsProperty(prop6));
- assertTrue(msg.containsProperty(prop7));
- assertTrue(msg.containsProperty(prop8));
- assertTrue(msg.containsProperty(prop9));
-
- assertEquals(val1, msg.getProperty(prop1));
- assertEquals(val2, msg.getProperty(prop2));
- assertEquals(val3, msg.getProperty(prop3));
- assertEquals(val4, msg.getProperty(prop4));
- assertEquals(val5, msg.getProperty(prop5));
- assertEquals(val6, msg.getProperty(prop6));
- assertEquals(val7, msg.getProperty(prop7));
- assertEquals(val8, msg.getProperty(prop8));
- assertEquals(val9, msg.getProperty(prop9));
-
- SimpleString val10 = new SimpleString(randomString());
- //test overwrite
- msg.putStringProperty(prop9, val10);
- assertEquals(val10, msg.getProperty(prop9));
-
- int val11 = randomInt();
- msg.putIntProperty(prop9, val11);
- assertEquals(val11, msg.getProperty(prop9));
-
- msg.removeProperty(prop1);
- assertEquals(8, msg.getPropertyNames().size());
- assertTrue(msg.getPropertyNames().contains(prop2));
- assertTrue(msg.getPropertyNames().contains(prop3));
- assertTrue(msg.getPropertyNames().contains(prop4));
- assertTrue(msg.getPropertyNames().contains(prop5));
- assertTrue(msg.getPropertyNames().contains(prop6));
- assertTrue(msg.getPropertyNames().contains(prop7));
- assertTrue(msg.getPropertyNames().contains(prop8));
- assertTrue(msg.getPropertyNames().contains(prop9));
-
- msg.removeProperty(prop2);
- assertEquals(7, msg.getPropertyNames().size());
- assertTrue(msg.getPropertyNames().contains(prop3));
- assertTrue(msg.getPropertyNames().contains(prop4));
- assertTrue(msg.getPropertyNames().contains(prop5));
- assertTrue(msg.getPropertyNames().contains(prop6));
- assertTrue(msg.getPropertyNames().contains(prop7));
- assertTrue(msg.getPropertyNames().contains(prop8));
- assertTrue(msg.getPropertyNames().contains(prop9));
-
- msg.removeProperty(prop9);
- assertEquals(6, msg.getPropertyNames().size());
- assertTrue(msg.getPropertyNames().contains(prop3));
- assertTrue(msg.getPropertyNames().contains(prop4));
- assertTrue(msg.getPropertyNames().contains(prop5));
- assertTrue(msg.getPropertyNames().contains(prop6));
- assertTrue(msg.getPropertyNames().contains(prop7));
- assertTrue(msg.getPropertyNames().contains(prop8));
-
- msg.removeProperty(prop3);
- msg.removeProperty(prop4);
- msg.removeProperty(prop5);
- msg.removeProperty(prop6);
- msg.removeProperty(prop7);
- msg.removeProperty(prop8);
- assertEquals(0, msg.getPropertyNames().size());
- }
- }
-
- // Protected -------------------------------------------------------------------------------
-
- protected void assertMessagesEquivalent(final Message msg1, final Message msg2)
- {
- assertEquals(msg1.isDurable(), msg2.isDurable());
-
- assertEquals(msg1.getExpiration(), msg2.getExpiration());
-
- assertEquals(msg1.getTimestamp(), msg2.getTimestamp());
-
- assertEquals(msg1.getPriority(), msg2.getPriority());
-
- assertEquals(msg1.getType(), msg2.getType());
-
- assertEqualsByteArrays(msg1.getBody().array(), msg2.getBody().array());
-
- assertEquals(msg1.getDestination(), msg2.getDestination());
-
- Set<SimpleString> props1 = msg1.getPropertyNames();
-
- Set<SimpleString> props2 = msg2.getPropertyNames();
-
- assertEquals(props1.size(), props2.size());
-
- for (SimpleString propname: props1)
- {
- Object val1 = msg1.getProperty(propname);
-
- Object val2 = msg2.getProperty(propname);
-
- assertEquals(val1, val2);
- }
- }
-
- // Private ----------------------------------------------------------------------------------
-
- private void checkSizes(final Message obj, final EncodingSupport newObject)
- {
- HornetQBuffer buffer = ChannelBuffers.buffer(1024);
- obj.encode(buffer);
- assertEquals (buffer.writerIndex(), obj.getEncodeSize());
- int originalSize = buffer.writerIndex();
-
- buffer.resetReaderIndex();
- newObject.decode(buffer);
-
-
- HornetQBuffer newBuffer = ChannelBuffers.buffer(1024);
-
- newObject.encode(newBuffer);
-
- assertEquals(newObject.getEncodeSize(), newBuffer.writerIndex());
- assertEquals(originalSize, newBuffer.writerIndex());
- }
-}
More information about the hornetq-commits
mailing list