Process state-machine and messenger for HTTP site deployment.
All listeners for a given channel are guaranteed to be called even if
others at the same channel fail. Each failure is logged, but execution
proceeds on to the next listener. The only way to stop all processing
from inside a listener is to raise SystemExit and stop the whole
server.
|
__init__(self)
x.__init__(...) initializes x; see x.__class__.__doc__ for signature |
source code
|
|
|
subscribe(self,
channel,
callback,
priority=None)
Add the given callback at the given channel (if not present). |
source code
|
|
|
unsubscribe(self,
channel,
callback)
Discard the given callback (if present). |
source code
|
|
|
publish(self,
channel,
*args,
**kwargs)
Return output of all subscribers for the given channel. |
source code
|
|
|
_clean_exit(self)
An atexit handler which asserts the Bus is not running. |
source code
|
|
|
|
|
exit(self)
Stop all services and prepare to exit the process. |
source code
|
|
|
|
|
graceful(self)
Advise all services to reload. |
source code
|
|
|
block(self,
interval=0.1)
Wait for the EXITING state, KeyboardInterrupt or SystemExit. |
source code
|
|
|
wait(self,
state,
interval=0.1)
Wait for the given state(s). |
source code
|
|
|
|
|
|
|
start_with_callback(self,
func,
args=None,
kwargs=None)
Start 'func' in a new thread T, then start self (and return T). |
source code
|
|
|
log(self,
msg='
' ,
level=20,
traceback=False)
Log the given message. |
source code
|
|
Inherited from object :
__delattr__ ,
__format__ ,
__getattribute__ ,
__hash__ ,
__new__ ,
__reduce__ ,
__reduce_ex__ ,
__repr__ ,
__setattr__ ,
__sizeof__ ,
__str__ ,
__subclasshook__
|