tethys.core.transports.connectors.connector_persist_queue

Module Contents

tethys.core.transports.connectors.connector_persist_queue.enable_callback_tracebacks[source]
class tethys.core.transports.connectors.connector_persist_queue.PersistQueueConnection(queue_path: str, queue_engine: str, recv_check_delay: float)[source]

Bases: tethys.core.transports.connectors.connector_base.ConnectionBase

Helper class that provides a standard way to create an ABC using inheritance.

Initialize self. See help(type(self)) for accurate signature.

property queue(self)[source]
recv_iter(self, **kwargs)[source]
send(self, data_packet, **kwargs)[source]
ack(self, message_key, **kwargs)[source]
open(self, **kwargs) → 'PersistQueueConnection'[source]
close(self, **kwargs) → 'PersistQueueConnection'[source]
class tethys.core.transports.connectors.connector_persist_queue.PersistQueueConnector(queue_dir=None, queue_engine='sqlite', recv_check_delay: float = 0.1)[source]

Bases: tethys.core.transports.connectors.connector_base.ConnectorBase

Initialize self. See help(type(self)) for accurate signature.

connect(self, channel_id: str, queue_engine: str = None, recv_check_delay: float = None, **kwargs) → 'PersistQueueConnection'[source]