org.hobbit.core.rabbit

Class DataReceiverImpl.MsgReceivingTask

java.lang.Object

org.hobbit.core.rabbit.DataReceiverImpl.MsgReceivingTask

All Implemented Interfaces:

Runnable

Enclosing class:

DataReceiverImpl

protected class DataReceiverImpl.MsgReceivingTask
extends Object
implements Runnable

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
void	run()
void	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()