flux.message module¶

class flux.message.Message(type_id=flux.constants.FLUX_MSGTYPE_REQUEST, handle=None)¶

Bases: flux.wrapper.WrapperPimpl

Flux message wrapper class.

class InnerWrapper(type_id=flux.constants.FLUX_MSGTYPE_REQUEST, handle=None)¶: Bases: flux.wrapper.Wrapper

classmethod from_event_encode(topic, payload=None)¶

property payload¶

property payload_str¶

property topic¶

property type¶

property type_str¶

class flux.message.MessageWatcher(flux_handle, type_mask, callback, topic_glob='*', match_tag=flux.constants.FLUX_MATCHTAG_NONE, args=None)¶

Bases: flux.core.watchers.Watcher

destroy()¶

start()¶

stop()¶

flux.message.msg_typestr(msg_type)¶