Practical Microservices

Sketching the Subscription Process

The subscription code falls into three categories:

• Managing the current read positionhere
• Fetching and processing batches of messageshere
• Orchestrating the subscriptionhere

The subscription code will use the Message Store for all of its data storage so you’ll get more practice writing to and reading from the store.

Before diving into these categories, let’s tour the basic shape of the subscription code. It’s found in video-tutorials/src/message-store/subscribe.js:

video-tutorials/src/message-store/subscribe.js

const Bluebird = require('bluebird')
const uuid = require('uuid/v4')

const category = require('./category')

function configureCreateSubscription ({ read, readLastMessage, write }) ...