gRPC Mission MQTT

gRPC MQTT Communication Module

Note

Features: - Continuous message sending from queue - Automatic reconnection on errors - Thread-safe operation

grpc_mission_mqtt.run_client(send_mqtt_queue: Queue, mission_logger: Logger) → None

Continuous client operation for sending MQTT messages via gRPC.

Parameters:

• send_mqtt_queue – Queue containing outgoing MQTT messages

• mission_logger – Configured logger instance for mission operations

Raises:

grpc.RpcError – For communication failures with the MQTT service

grpc_mission_mqtt.start_grpc_mission_mqtt(send_mqtt_queue: Queue, mission_logger: Logger) → None

Initialize and start the MQTT gRPC client thread.

Parameters:

• send_mqtt_queue – Thread-safe queue for outgoing messages

• mission_logger – Configured logger instance

Example

>>> start_grpc_mission_mqtt(message_queue, logger)