flux.message module

class flux.message.Message(type_id=<sphinx.ext.autodoc.importer._MockObject object>, handle=None, destruct=False)

Bases: flux.wrapper.WrapperPimpl

Flux message wrapper class.

class InnerWrapper(type_id=<sphinx.ext.autodoc.importer._MockObject object>, handle=None, destruct=False)

Bases: flux.wrapper.Wrapper

classmethod from_event_encode(topic, payload=None)
payload
payload_str
topic
type
type_str
class flux.message.MessageWatcher(flux_handle, type_mask, callback, topic_glob='*', match_tag=<sphinx.ext.autodoc.importer._MockObject object>, args=None)

Bases: flux.core.watchers.Watcher

destroy()
start()
stop()
flux.message.msg_typestr(msg_type)