tethys.core.transports.connectors.connector_rabbitmq

Module Contents

class tethys.core.transports.connectors.connector_rabbitmq.RabbitMQConnection(queue: str, connection_params: Union[dict, str])[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.

recv_iter(self, **kwargs)[source]
send(self, data_packet, **kwargs)[source]
ack(self, message_key, **kwargs)[source]
open(self, **kwargs) → 'RabbitMQConnection'[source]
close(self, **kwargs) → 'RabbitMQConnection'[source]
class tethys.core.transports.connectors.connector_rabbitmq.RabbitMQConnector(connection_params: Union[dict, str])[source]

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

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

connect(self, queue: str, **kwargs) → 'RabbitMQConnection'[source]