We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
mqtt
Introduce with clause to mqtt routing supporting reference to ${guarded['...'].identity} to implicitly scope topic and reply topic names as needed.
with
${guarded['...'].identity}
mqtt_server0: type: mqtt kind: server routes: - when: - publish: - topic: event exit: mqtt_kafka_proxy0 with: topic: event/${guarded['jwt'].identity} - when: - publish: - topic: command reply-to: reply exit: mqtt_kafka_proxy0 with: topic: command/${guarded['jwt'].identity} reply-to: reply/${guarded['jwt'].identity} - when: - subscribe: - topic: reply exit: mqtt_kafka_proxy0 with: topic: reply/${guarded['jwt'].identity} - when: - session: - client-id: * exit: mqtt_kafka_proxy0
Note: depends on #420
The text was updated successfully, but these errors were encountered:
mqtt-kafka
No branches or pull requests
Introduce
with
clause tomqtt
routing supporting reference to${guarded['...'].identity}
to implicitly scope topic and reply topic names as needed.Note: depends on #420
The text was updated successfully, but these errors were encountered: