In an earlier blog post, I explained how to build a simple chat browser application that consumes messages via a direct topic subscription. In this follow-up to that tutorial, I’ll explain how to modify the sample code to get that application consuming messages from a queue.

Specifically, you will create a queue, add a subscription to the queue and create the queue consumer.

Prerequisites:

Level: Beginner

Create a Queue

  1. In your code editor, check out the developer-exercise-2 branch or in your command line, enter git checkout remotes/origin/developer-exercise-2 -f
  2. Open the scripts directory under src > main > resources > static.
  3. Open the pubsubplusbroker.js file, comment out the direct topic subscription that was added in Part 1 and save the file.
  4. Log in to Solace PubSub+ Cloud, open your service, and click Manage Service.
  5. Click the Queues tab on the left.
  6. Click the + Create button to create a queue.
  7. In the Create Queue dialog box, give the queue a name and click the Create button.

  8. Click Apply to use the default settings.

Add a Subscription to the Queue

  1. Click on the queue you just created and click the Subscriptions tab.
  2. Click the + Subscription button to open the Create Subscription dialog box.
  3. In the Create Subscription dialog box, add the topic subscription, press Enter, and click Create.
  4. In your code editor, type mvn spring-boot:run to run the application. Make sure you are in the \web-app-server directory.
  5. In your Web browser, type localhost:8081 to open the application if it is not already open.
  6. Send a few messages in the application.
  7. In the queue you created at Step 3, click Summary to see the queued messages.

Create the Queue Consumer

Now that the messages are in the queue, you need to create the consumer that consumes the messages in the queue. To create the consumer, follow the steps below:

  1. Open the application-properties.js file under static > resources and add ‘SOLACE_CHAT’ to sReceiveQueue.
  2. Open the pubsubplusbroker.js file, specify the queue descriptor, including the name and type of the queue, and set the acknowledge mode.
  3. Add the following code to connect the message consumer.
  4. In your code editor, type mvn spring-boot:run to run the application.
  5. Refresh the chat application in your browser.
    You should be able to see the received messages from the broker.
  6. In the queue that you created earlier, click Summary and then Refresh Data in the bottom right corner. You should see that the messages are no longer in the queue because of auto acknowledgement.

Congratulations! You have just created a queue, added a subscription to the queue, and created the queue consumer. In Part 3 of the series, you will learn how to send a REST POST request from a login page to a dummy authentication service.

Related

Hong Qiu
Hong Qiu

Hong is the Senior Community Manager at Solace, where he is responsible for building and managing the Solace community and creating developer-focused content. Prior to Solace, he spent over 10 years at Adobe managing the Adobe Developer Connection portals and planning, creating, and sourcing content for them. Before Adobe, he was a senior technical writer at Nortel and a technical writer at Cognos (now IBM).

See all posts written by Hong Qiu
Solly
Solly

Subscribe to Our Blog
Get the latest trends, solutions, and insights into the event-driven future every week.

Thanks for subscribing.