org.skyscreamer.nevado.jms

Class AsyncConsumerRunner

java.lang.Object

org.skyscreamer.nevado.jms.AsyncConsumerRunner

All Implemented Interfaces:

Runnable

public class AsyncConsumerRunner
extends Object
implements Runnable

Asynchronous processor for consumers with registered message listeners

Author:

Carter Page

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AsyncConsumerRunner(NevadoConnection connection)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAsyncConsumer(NevadoMessageConsumer asyncConsumer)
int	numAsyncConsumers()
void	removeAsyncConsumer(NevadoMessageConsumer asyncConsumer)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncConsumerRunner

protected AsyncConsumerRunner(NevadoConnection connection)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

addAsyncConsumer

public void addAsyncConsumer(NevadoMessageConsumer asyncConsumer)

removeAsyncConsumer

public void removeAsyncConsumer(NevadoMessageConsumer asyncConsumer)

numAsyncConsumers

public int numAsyncConsumers()