demessaging.messaging.connection module
Base module for a websocket connection.
Classes:
|
Base class to connect to a message broker using a websocket. |
Functions:
|
- 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])