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

Class QueuingMessageBus

source code

messagebus.MessageBus --+

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]


source code 
Overrides: messagebus.MessageBus.__init__