Package horizons :: Package messaging :: Module queuingmessagebus :: Class QueuingMessageBus
[hide private]
[frames] | no frames]

Class QueuingMessageBus

source code

messagebus.MessageBus --+
                        |
                       QueuingMessageBus

The QueuingMessageBus class is used to send Message instances from a sender to one or multiple recipients, with the additional property that messages will be saved to a queue if no callback is subscribed at the time they are sent.

Instance Methods [hide private]
 
__init__(self) source code
 
subscribe_globally(self, messagetype, callback) source code
 
subscribe_locally(self, messagetype, instance, callback) source code
 
broadcast(self, message) source code
 
clear(self, messagetype) source code
 
queue_len(self, messagetype) source code
 
reset(self) source code
Class Variables [hide private]

Inherited from messagebus.MessageBus: log

Method Details [hide private]

__init__(self)
(Constructor)

source code 
Overrides: messagebus.MessageBus.__init__