wotpy.protocols.zenoh.handlers.base

Base class for all Zenoh handlers.

Classes

BaseZenohHandler(zenoh_server)

Base class for all Zenoh handlers.

class wotpy.protocols.zenoh.handlers.base.BaseZenohHandler(zenoh_server)

Bases: object

Base class for all Zenoh handlers.

async handle_message(sample)

Called each time the runner receives a message for one of the handler topics.

async init()

Initializes the Zenoh handler. Called when the Zenoh runner starts.

property queue

Asynchronous queue where the handler leaves messages that should be published later by the runner.

property servient_id

Servient ID that is used to avoid topic collisions when multiple Servients are connected to the same broker.

property subscriber

Zenoh Subscriber that can be used to fetch queued messages.

async teardown()

Destroys the Zenoh handler. Called when the Zenoh runner stops.

property topics

List of topics that this Zenoh handler wants to subscribe to.

property zenoh_server

Zenoh server that contains this handler.