public class PendingMessageQueueTest extends Object
PendingMessageQueue
.Modifier and Type | Class and Description |
---|---|
static class |
PendingMessageQueueTest.FastConsumer
FastConsumer provides a fast consumer of messages.
|
static class |
PendingMessageQueueTest.FastProducer
FastProducer provides a fast producer of messages.
|
static class |
PendingMessageQueueTest.SlowConsumer
SlowConsumer provides a slow consumer of messages.
|
static class |
PendingMessageQueueTest.SlowProducer
SlowProducer provides a slow producer of messages.
|
Constructor and Description |
---|
PendingMessageQueueTest() |
public void testDrainTo()
PendingMessageQueue.drainTo(List)
.public void testDrainToWithLowLatencyLock()
PendingMessageQueue.drainTo(List)
.public void testMultipleFastProducerFastConsumer() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testMultipleFastProducerFastConsumerWithLowLatencyLock() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testMultipleSlowProducerFastConsumer() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testMultipleSlowProducerFastConsumerWithLowLatencyLock() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testOfferPendingMessage()
PendingMessageQueue.offer(PendingMessage)
.public void testOfferPendingMessageWhenFull()
PendingMessageQueue.offer(PendingMessage)
.public void testOfferPendingMessageWhenFullWithLowLatencyLock()
PendingMessageQueue.offer(PendingMessage)
.public void testOfferPendingMessageWithLowLatencyLock()
PendingMessageQueue.offer(PendingMessage)
.public void testPendingMessageQueue()
PendingMessageQueue.PendingMessageQueue(int, LockType)
.public void testPendingMessageQueueNonPowerOfTwo()
PendingMessageQueue.PendingMessageQueue(int, LockType)
.public void testPendingMessageQueueNonPowerOfTwoWithLowLatencyLock()
PendingMessageQueue.PendingMessageQueue(int, LockType)
.public void testPendingMessageQueueTooBig()
PendingMessageQueue.PendingMessageQueue(int, LockType)
.public void testPendingMessageQueueTooBigWithLowLatencyLock()
PendingMessageQueue.PendingMessageQueue(int, LockType)
.public void testPendingMessageQueueWithLowLatencyLock()
PendingMessageQueue.PendingMessageQueue(int, LockType)
.public void testPoll()
public void testPollNotStarted()
public void testPollNotStartedWithLowLatencyLock()
public void testPollWithLowLatencyLock()
public void testPutIntMessageCallbackOfReply()
PendingMessageQueue.put(Message, ReplyCallback)
.public void testPutIntMessageCallbackOfReplyIntMessageCallbackOfReply()
PendingMessageQueue.put(Message, ReplyCallback, Message, ReplyCallback)
.public void testPutIntMessageCallbackOfReplyIntMessageCallbackOfReplyWhenFull()
PendingMessageQueue.put(Message, ReplyCallback, Message, ReplyCallback)
.public void testPutIntMessageCallbackOfReplyIntMessageCallbackOfReplyWhenFullWithLowLatencyLock()
PendingMessageQueue.put(Message, ReplyCallback, Message, ReplyCallback)
.public void testPutIntMessageCallbackOfReplyIntMessageCallbackOfReplyWithLowLatencyLock()
PendingMessageQueue.put(Message, ReplyCallback, Message, ReplyCallback)
.public void testPutIntMessageCallbackOfReplyWhenFull()
PendingMessageQueue.put(Message, ReplyCallback)
.public void testPutIntMessageCallbackOfReplyWhenFullWithLowLatencyLock()
PendingMessageQueue.put(Message, ReplyCallback)
.public void testPutIntMessageCallbackOfReplyWithLowLatencyLock()
PendingMessageQueue.put(Message, ReplyCallback)
.public void testPutPendingMessage()
PendingMessageQueue.put(PendingMessage)
.public void testPutPendingMessageWhenFull()
PendingMessageQueue.put(PendingMessage)
.public void testPutPendingMessageWhenFullWithLowLatencyLock()
PendingMessageQueue.put(PendingMessage)
.public void testPutPendingMessageWithLowLatencyLock()
PendingMessageQueue.put(PendingMessage)
.public void testSingleProducerFastConsumer() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testSingleProducerFastConsumerWithLowLatencyLock() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testSingleProducerSlowConsumer() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testSingleProducerSlowConsumerWithLowLatencyLock() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testSingleSlowProducerFastConsumer() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testSingleSlowProducerFastConsumerWithLowLatencyLock() throws InterruptedException
InterruptedException
- On a failure waiting for the test.public void testTake()
public void testTakeExhuasted()
public void testTakeExhuastedWithLowLatencyLock()
public void testTakeNotStarted()
public void testTakeNotStartedWithLowLatencyLock()
public void testTakeWithLowLatencyLock()
protected void waitForDone(int count, PendingMessageQueue queue, PendingMessageQueueTest.FastConsumer consumer) throws InterruptedException
count
- The expected count.queue
- The queue to be emptied.consumer
- The consumer reading.InterruptedException
- On a failure to sleep.protected void waitForDone(int count, PendingMessageQueue queue, PendingMessageQueueTest.SlowConsumer consumer) throws InterruptedException
count
- The expected count.queue
- The queue to be emptied.consumer
- The consumer reading.InterruptedException
- On a failure to sleep.Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.