Shared Subscription about fastapi-mqtt HOT 3 CLOSED

#55 does not solve it, since it is a matter of processing topic matches rather than additional parameters. #81 fixes it, though.
There are also a discussion if this package will support broker-specific subscription topics such as emqx $queue and $exclusive topics.

from fastapi-mqtt.

Hi,

I have found this as well. This function does not work.

@fast_mqtt.subscribe("$share/group1/test/topic")
async def message_to_shared_topic(client, topic, payload, qos, properties):
    print(
        "Received message to SHARED topic: ", topic, payload.decode(), qos, properties
    )

When publishing to the topic test/topic, nothing arrives.

However, if I also subscribe to the topic test/topic using this function:

@fast_mqtt.subscribe("test/topic")
async def message_to_topic(client, topic, payload, qos, properties):
    print(
        "Received message to specific topic: ", topic, payload.decode(), qos, properties
    )

I receive two messages whenever a message is published to test/topic.

Any help would be gratefully received.

from fastapi-mqtt.

Hey there, I see your concerns about it, checking PR #55, thinking this PR can solve the current issue

from fastapi-mqtt.