niryo_libraries.rosbridge_library.internal.subscription_modifiers.QueueMessageHandler

class documentation

class QueueMessageHandler(MessageHandler, Thread):

Constructor: QueueMessageHandler(previous_handler)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method finish If throttle was set to 0, this pushes all buffered messages
Method handle_message Undocumented
Method run Undocumented
Method transition Undocumented
Instance Variable alive Undocumented
Instance Variable c Undocumented
Instance Variable daemon Undocumented
Instance Variable queue Undocumented

Inherited from MessageHandler:

Method set_queue_length Undocumented
Method set_throttle_rate Undocumented
Method time_remaining Undocumented
Instance Variable last_publish Undocumented
Instance Variable publish Undocumented
Instance Variable queue_length Undocumented
Instance Variable throttle_rate Undocumented
def __init__(self, previous_handler):
overrides niryo_libraries.rosbridge_library.internal.subscription_modifiers.MessageHandler.__init__

Undocumented

def finish(self, block=True):
overrides niryo_libraries.rosbridge_library.internal.subscription_modifiers.MessageHandler.finish

If throttle was set to 0, this pushes all buffered messages

def handle_message(self, msg):
overrides niryo_libraries.rosbridge_library.internal.subscription_modifiers.MessageHandler.handle_message

Undocumented

def run(self):

Undocumented

def transition(self):
overrides niryo_libraries.rosbridge_library.internal.subscription_modifiers.MessageHandler.transition

Undocumented

alive: bool =

Undocumented

c =

Undocumented

daemon: bool =

Undocumented

queue =

Undocumented