Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

It seems topic parameters do not support subscription to multiple topics. #43

Open
weiping-code opened this issue Oct 8, 2019 · 1 comment

Comments

@weiping-code
Copy link

https://github.com/siddhi-io/siddhi-io-mqtt/blob/master/component/src/main/java/io/siddhi/extension/io/mqtt/source/MqttConsumer.java#L52
it,s not working when I set the topic parameter as this '/mqtt/topic1,/mqtt/topic2'. It seems topic parameters do not support subscription to multiple topics. It is necessary to separate the topic into multiple topics according to the comma when parsing the topic parameter.

@mohanvive
Copy link
Contributor

mohanvive commented Nov 8, 2019

As you mentioned, our current implement does not support to add multiple topics to the same source configuration. If you wanted to consume from multiple topics then you have to add separate source configuration for each of them..

It would be a simple fix, please send a PR if you like to contribute.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants