A sample node express application which uses mqtt to exchange messages with a Solace PubSub+ broker.
- The express logic is in src/index.js
- The application logic is in src/App.js
- The messaging API is in src/Messaging.js
- The connection parameters are in src/messaging-options.js
- Head over to your service dashboard and select the Connect tab.
- Open the MQTT tab and copy the contents of
PasswordandWebSocket Secured MQTT Host
- Paste the contents into the respective labels in the
/src/messaging-options.jssource file
- npm install
- npm run dev
If the Solace broker configuration is correct, you should see the following log:
Succesfully connected to Solace Cloud. Connected!
If you don't see this log, see the section "How to connect to Solace Broker"
By default, the application will connect to the Solace broker configured using the steps above.
The express server is setup with two endpoints which allow you to subscribe and publish.
First you will need to subscribe to a Topic. To do that, initiate a POST operation to http://localhost:9001/subscribe
curl -X POST localhost:9001/subscribe
Now your app is subscribed to the SomeTopic topic.
Next, puslish a message to this topic using the publish endpoint
curl -X POST localhost:9001/publish
At this point you should see a log
New message on topic: SomeTopic :: {"text":"Hello"}
Message as object { text: 'Hello' }
If you don't see this log, see the section "How to connect to Solace Broker"