rosbridge_server.websocket_handler module

class rosbridge_server.websocket_handler.IncomingQueue(protocol)

Bases: Thread

Decouples incoming messages from the Tornado thread.

This mitigates cases where outgoing messages are blocked by incoming, and vice versa.

finish()

Clear the queue and do not accept further messages.

push(msg)

run()

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.

class rosbridge_server.websocket_handler.RosbridgeWebSocket(*args: Any, **kwargs: Any)

Bases: WebSocketHandler

bson_only_mode = False

check_origin(origin)

clients_connected = 0

delay_between_messages = 0

fragment_timeout = 600

get_compression_options()

max_message_size = 10000000

node_handle = None

on_close()

on_message(message)

open()

async prewrite_message(message, binary)

send_message(message, compression='none')

unregister_timeout = 10.0

use_compression = False

rosbridge_server.websocket_handler.log_exceptions(f)

Log exceptions to ROS.