1 18 package org.apache.activemq.memory.buffer; 19 20 import org.apache.activemq.memory.buffer.MessageBuffer; 21 import org.apache.activemq.memory.buffer.OrderBasedMessageBuffer; 22 23 27 public class OrderBasedMemoryBufferTest extends MemoryBufferTestSupport { 28 29 public void testSizeWorks() throws Exception { 30 qA.add(createMessage(10)); 31 qB.add(createMessage(10)); 32 qB.add(createMessage(10)); 33 qC.add(createMessage(10)); 34 35 dump(); 36 37 assertEquals("buffer size", 40, buffer.getSize()); 38 assertEquals("qA", 10, qA.getSize()); 39 assertEquals("qB", 20, qB.getSize()); 40 assertEquals("qC", 10, qC.getSize()); 41 42 qC.add(createMessage(10)); 43 44 dump(); 45 46 assertEquals("buffer size", 40, buffer.getSize()); 47 assertEquals("qA", 0, qA.getSize()); 48 assertEquals("qB", 20, qB.getSize()); 49 assertEquals("qC", 20, qC.getSize()); 50 51 qB.add(createMessage(10)); 52 53 dump(); 54 55 assertEquals("buffer size", 40, buffer.getSize()); 56 assertEquals("qA", 0, qA.getSize()); 57 assertEquals("qB", 20, qB.getSize()); 58 assertEquals("qC", 20, qC.getSize()); 59 60 qA.add(createMessage(10)); 61 62 dump(); 63 64 assertEquals("buffer size", 40, buffer.getSize()); 65 assertEquals("qA", 10, qA.getSize()); 66 assertEquals("qB", 10, qB.getSize()); 67 assertEquals("qC", 20, qC.getSize()); 68 } 69 70 71 protected MessageBuffer createMessageBuffer() { 72 return new OrderBasedMessageBuffer(40); 73 } 74 } 75 | Popular Tags |