1 18 package org.apache.activemq.memory.buffer; 19 20 import org.apache.activemq.memory.buffer.MessageBuffer; 21 import org.apache.activemq.memory.buffer.SizeBasedMessageBuffer; 22 23 27 public class SizeBasedMessageBufferTest 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)); 44 45 dump(); 46 47 assertEquals("buffer size", 40, buffer.getSize()); 48 assertEquals("qA", 10, qA.getSize()); 49 assertEquals("qB", 10, qB.getSize()); 50 assertEquals("qC", 20, qC.getSize()); 51 } 52 53 54 protected MessageBuffer createMessageBuffer() { 55 return new SizeBasedMessageBuffer(40); 56 } 57 } 58 | Popular Tags |