org.hobbit.core.rabbit.consume

Class QueueingConsumerBasedImpl.MsgReceivingTask

java.lang.Object

org.hobbit.core.rabbit.consume.QueueingConsumerBasedImpl.MsgReceivingTask

All Implemented Interfaces:

Runnable, Terminatable, TerminatableRunnable

Enclosing class:

QueueingConsumerBasedImpl

protected class QueueingConsumerBasedImpl.MsgReceivingTask
extends Object
implements TerminatableRunnable

Field Summary

Fields

Modifier and Type	Field and Description
private com.rabbitmq.client.QueueingConsumer	consumer
private boolean	runFlag

Constructor Summary

Constructors

Constructor and Description
MsgReceivingTask(com.rabbitmq.client.QueueingConsumer consumer)

Method Summary

Modifier and Type	Method and Description
boolean	isTerminated() Returns a flag whether the object has been asked to terminate.
void	run()
void	terminate() Informs the object that it should terminate.

Methods inherited from class java.lang.Object

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

Field Detail

consumer

private com.rabbitmq.client.QueueingConsumer consumer

runFlag

private boolean runFlag

Constructor Detail

MsgReceivingTask

public MsgReceivingTask(com.rabbitmq.client.QueueingConsumer consumer)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

terminate

public void terminate()

Description copied from interface: Terminatable

Informs the object that it should terminate. Note that there is no guarantee that the termination will happen while this method is running, i.e., this method is not blocking and won't wait for the object to terminate.

Specified by:

terminate in interface Terminatable

isTerminated

public boolean isTerminated()

Description copied from interface: Terminatable

Returns a flag whether the object has been asked to terminate. Note that if the method returns true, it does not have to be terminated.

Specified by:

isTerminated in interface Terminatable

Returns:

returns true if it received a request to terminate