Package pulp :: Package messaging :: Module consumer :: Class ReceiverThread

Class ReceiverThread

        object --+        
                 |        
threading._Verbose --+    
                     |    
      threading.Thread --+
                         |
                        ReceiverThread

Consumer (worker) thread.

Instance Methods

[hide private]

__init__(self, consumer)
x.__init__(...) initializes x; see x.__class__.__doc__ for signature

source code

run(self)
Messages are read from consumer.receiver and dispatched to the consumer.received().

source code

stop(self)
Stop reading the receiver and terminate the thread.

source code

Inherited from threading.Thread: __repr__, getName, isAlive, isDaemon, join, setDaemon, setName, start

Inherited from threading.Thread (private): _set_daemon

Inherited from threading._Verbose (private): _note

Inherited from object: __delattr__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __setattr__, __str__

Instance Variables

[hide private]

bool

__run
The main run/read flag.

Consumer

consumer
A consumer that is notified when messages are read.

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, consumer)
(Constructor)

source code

x.__init__(...) initializes x; see x.__class__.__doc__ for signature

Parameters:

consumer (Consumer) - A consumer that is notified when messages are read.

Overrides: object.__init__

run(self)

source code

Messages are read from consumer.receiver and dispatched to the consumer.received().

Overrides: threading.Thread.run

Class ReceiverThread

__init__(self, consumer) (Constructor)

run(self)

init(self, consumer)
(Constructor)