DataReceiverImpl.MsgReceivingTask (core 1.0.17 API)

java.lang.Object
- org.hobbit.core.rabbit.DataReceiverImpl.MsgReceivingTask

All Implemented Interfaces:: Runnable, Terminatable, TerminatableRunnable

Enclosing class:: DataReceiverImpl

protected class DataReceiverImpl.MsgReceivingTask
extends Object
implements TerminatableRunnable

Field Summary

Fields
Modifier and Type Field Description

private com.rabbitmq.client.QueueingConsumer consumer

private boolean runFlag

private boolean terminatedFlag

Constructor Summary

Constructors
Constructor Description

MsgReceivingTask(com.rabbitmq.client.QueueingConsumer consumer)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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
```
  - terminatedFlag
```
private boolean terminatedFlag
```
- 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