com.allanbank.mongodb.client.message

Class PendingMessageQueueTest.FastProducer

java.lang.Object

com.allanbank.mongodb.client.message.PendingMessageQueueTest.FastProducer

All Implemented Interfaces:

Runnable

Enclosing class:

PendingMessageQueueTest

public static final class PendingMessageQueueTest.FastProducer
extends Object
implements Runnable

FastProducer provides a fast producer of messages.

Copyright ©:

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

Constructor Summary

Constructors

Constructor and Description
PendingMessageQueueTest.FastProducer(PendingMessageQueue queue, int count) Creates a new FastProducer.

Method Summary

Methods

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

PendingMessageQueueTest.FastProducer

public PendingMessageQueueTest.FastProducer(PendingMessageQueue queue,
                                    int count)

Creates a new FastProducer.

Parameters:

queue - The queue to write to.

count - The number of messages to produce.

Method Detail

run

public void run()

Specified by:

run in interface Runnable