resonate.message_sources.LocalMessageSource

class documentation

class LocalMessageSource:

Constructor: LocalMessageSource(store, group, id, scheme)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method enqueue Undocumented
Method next Undocumented
Method start Undocumented
Method stop Undocumented
Property anycast Undocumented
Property group Undocumented
Property id Undocumented
Property unicast Undocumented
Instance Variable _group Undocumented
Instance Variable _id Undocumented
Instance Variable _messages Undocumented
Instance Variable _scheme Undocumented
Instance Variable _store Undocumented
def __init__(self, store: LocalStore, group: str, id: str, scheme: str = 'local'):

Undocumented

def enqueue(self, mesg: Mesg):

Undocumented

def next(self) -> Mesg | None:

Undocumented

def start(self):

Undocumented

def stop(self):

Undocumented

@property
anycast: str =

Undocumented

@property
group: str =

Undocumented

@property
id: str =

Undocumented

@property
unicast: str =

Undocumented

_group =

Undocumented

_id =

Undocumented

_messages =

Undocumented

_scheme =

Undocumented

_store =

Undocumented