demessaging.messaging.connection module

Base module for a websocket connection.

Classes:

WebsocketConnection(pulsar_config)

Base class to connect to a message broker using a websocket.

Functions:

get_random_letters(length)

class demessaging.messaging.connection.WebsocketConnection(pulsar_config: BaseMessagingConfig)[source]

Bases: ABC

Base class to connect to a message broker using a websocket.

Methods:

create_websocketapp([subscription, topic])

generate_response_topic([topic])

on_close(ws_app, close_status_code, close_msg)

on_message(ws_app, msg)

on_ping(ws_app, payload)

on_pong(ws_app, payload)

open_socket([subscription, topic])

create_websocketapp(subscription: str | None = None, topic: str | None = None, **app_kws) → WebSocketApp[source]
generate_response_topic(topic: str | None = None) → str[source]
on_close(ws_app: WebSocketApp, close_status_code, close_msg)[source]
on_message(ws_app: WebSocketApp, msg)[source]
on_ping(ws_app: WebSocketApp, payload)[source]
on_pong(ws_app: WebSocketApp, payload)[source]
open_socket(subscription: str | None = None, topic: str | None = None, **connection_kws) → WebSocket[source]
demessaging.messaging.connection.get_random_letters(length: int) → str[source]