from pip_services3_mqtt.queues import MqttMessageQueue