Skip to main content

Publish / Subscribe Example

How to use​

  • install all dependencies

npm i

  • open 7 terminals
  • 1st terminal run server

node server.js

  • 2nd terminal run 1st subscriber

TOPIC_ID=stock_prices node subscriber.js

  • 3rd terminal run 2nd subscriber with the same topic as the 1st subscriber

TOPIC_ID=stock_prices node subscriber.js

  • 4th terminal run 3rd subscriber with different topic

TOPIC_ID=news_alerts node subscriber.js

  • 5th terminal run 1st publisher

(for i in seq 1 10000; do sleep 1; echo New Stock Price; done) | NAME=STOCK_BROKER TOPIC_ID=stock_prices node publisher.js

  • 1st and 2nd subscriber will receive the notifications
  • 6th terminal run 2nd publisher

(for i in seq 1 10000; do sleep 1; echo Breaking News; done) | NAME=NEWS_STATION TOPIC_ID=news_alerts node publisher.js

  • only the 3rd subscriber will receive the notifications
  • 7th terminal run 3rd publisher

(for i in seq 1 10000; do sleep 1; echo Youtube Notification; done) | NAME=YOUTUBE TOPIC_ID=youtube_notifications node publisher.js

  • none of the subscriber will receive any notifications