739740741742743744745746747748749
; msgIds = getMessageIds(); assertEquals(10, msgIds.size()); assertSameIds(msgIds, refs, 231, 240); //Verify 100 refs in queue assertEquals(100, queue.memoryRefCount()); //Verify paging assertTrue(queue.isPaging()); //Verify 10 deliveries
770771772773774775776777778779780
; msgIds = getMessageIds(); assertEquals(20, msgIds.size()); assertSameIds(msgIds, refs, 221, 240); //Verify 100 refs in queue assertEquals(100, queue.memoryRefCount()); //Verify paging assertTrue(queue.isPaging()); //Verify 0 deliveries
804805806807808809810811812813814
assertEquals(0, queue.getDeliveringCount()); assertEquals(0, queue.downCacheCount()); //Verify 70 refs in queue assertEquals(70, queue.memoryRefCount()); // Verify not paging assertFalse(queue.isPaging());
826827828829830831832833834835836
//Verify 0 msgs in storage ; msgIds = getMessageIds(); assertEquals(0, msgIds.size()); //Verify 0 refs in queue assertEquals(0, queue.memoryRefCount()); //Make sure there are no more refs in queue assertEquals(0, queue.getMessageCount()); }
109110111112113114115116117118119
assertEquals(0, refIds.size()); refIds = getReferenceIdsOrderedByOrd(queue2.getChannelID()); assertEquals(50, refIds.size()); assertEquals(50, queue2.memoryRefCount()); assertEquals(0, queue2.downCacheCount()); assertTrue(queue2.isPaging());
102103104105106107108109110111112
//Queue2 refIds = getReferenceIdsOrderedByPageOrd(queue2.getChannelID()); assertEquals(0, refIds.size()); assertEquals(50, queue2.memoryRefCount()); assertEquals(0, queue2.downCacheCount()); assertTrue(queue2.isPaging());
149150151152153154155156157158159
//Queue2 refIds = getReferenceIdsOrderedByPageOrd(queue2.getChannelID()); assertEquals(25, refIds.size()); assertEquals(50, queue2.memoryRefCount()); assertEquals(0, queue2.downCacheCount()); assertTrue(queue2.isPaging());
196197198199200201202203204205206
//Queue2 refIds = getReferenceIdsOrderedByPageOrd(queue2.getChannelID()); assertEquals(50, refIds.size()); assertEquals(50, queue2.memoryRefCount()); assertEquals(0, queue2.downCacheCount()); assertTrue(queue2.isPaging());
244245246247248249250251252253254
//Queue2 refIds = getReferenceIdsOrderedByPageOrd(queue2.getChannelID()); assertEquals(100, refIds.size()); assertEquals(50, queue2.memoryRefCount()); assertEquals(0, queue2.downCacheCount()); assertTrue(queue2.isPaging());
287288289290291292293294295296297
//Queue2 refIds = getReferenceIdsOrderedByPageOrd(queue2.getChannelID()); assertEquals(0, refIds.size()); assertEquals(0, queue2.memoryRefCount()); assertEquals(0, queue2.downCacheCount()); assertFalse(queue2.isPaging());