com.allanbank.mongodb.client.message

Class PendingMessageQueueTest.SlowConsumer

java.lang.Object

com.allanbank.mongodb.client.message.PendingMessageQueueTest.SlowConsumer

All Implemented Interfaces:

Runnable

Enclosing class:

PendingMessageQueueTest

public static final class PendingMessageQueueTest.SlowConsumer
extends Object
implements Runnable

SlowConsumer provides a slow consumer of messages.

Copyright ©:

2012-2013, Allanbank Consulting, Inc., All Rights Reserved

Constructor Summary

Constructors

Constructor and Description
PendingMessageQueueTest.SlowConsumer(PendingMessageQueue queue) Creates a new SlowConsumer.

Method Summary

Methods

Modifier and Type	Method and Description
int	getCount() Returns the count value.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PendingMessageQueueTest.SlowConsumer

public PendingMessageQueueTest.SlowConsumer(PendingMessageQueue queue)

Creates a new SlowConsumer.

Parameters:

queue - The queue to consume from.

Method Detail

getCount

public int getCount()

Returns the count value.

Returns:

The count value.

run

public void run()

Specified by:

run in interface Runnable