# Read (forever) example
$ plumber read message mqtt --topic dantest -d -f --line-numbers --address tcp://test.mosquitto.org:1883
# Write example
$ plumber write message mqtt --topic dantest --input-data testing --address tcp://test.mosquitto.org:1883
# Read (forever) with protobuf
$ plumber read message mqtt --topic dantest --address tcp://test.mosquitto.org:1883 -d -f --line-numbers --output-type protobuf --protobuf-dir ./test-assets/protos --protobuf-root-message Outbound
# Write protobuf
$ plumber write message mqtt --topic dantest --address tcp://test.mosquitto.org:1883 --input-file ./test-assets/messages/sample-outbound.json --input-type jsonpb --output-type protobuf --protobuf-dir ./test-assets/protos --protobuf-root-message Outbound
