com.allanbank.mongodb.client.message

Class PendingMessageQueueTest.FastConsumer

java.lang.Object

com.allanbank.mongodb.client.message.PendingMessageQueueTest.FastConsumer

All Implemented Interfaces:

Runnable

Enclosing class:

PendingMessageQueueTest

public static final class PendingMessageQueueTest.FastConsumer
extends Object
implements Runnable

FastConsumer provides a fast consumer of messages.

Copyright ©:

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

Constructor Summary

Constructors

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

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.FastConsumer

public PendingMessageQueueTest.FastConsumer(PendingMessageQueue queue)

Creates a new FastConsumer.

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