demessaging.messaging.consumer module
Consumer for messages submitted via the message broker.
Classes:
|
Consumer for messages submitted via the message broker. |
- class demessaging.messaging.consumer.MessageConsumer(pulsar_config: BaseMessagingConfig, handle_request, handle_response=None, module_info: dict | None = None, api_info: ModuleAPIModel | None = None)[source]
Bases:
WebsocketConnection
Consumer for messages submitted via the message broker.
Attributes:
Methods:
acknowledge
(msg)close_websocket_app
(ws_app[, reason])extract_context
(msg)extract_message_type
(msg)handle_api_info
(api_info_request)Show the api of the module.
handle_info
(info_request)handle_pong
(request)is_valid_request
(request_message)is_valid_value
(value)on_message
(ws_app, msg)on_producer_message
(ws_app, msg)open_producer_app
(topic, **kwargs)reset_close_timer
(ws_app)send_error
(request, error_message)send_pong
(request)send_response
(request[, response_payload, ...])wait_for_websocket_connection
(ws_app[, timeout])- RECONNECT_TIMEOUT_SLEEP = 10
- SOCKET_PING_INTERVAL = 60
- request_semaphore: BoundedSemaphore | None