sample nats-streaming-cluster

s1.conf

listen: "localhost:4222"
cluster: {
  listen: "localhost:4333"
}
streaming: {
  store: "file"
  dir: "/tmp/stan-cluster/data"
  ft_group: "ft"
}

s2.conf

listen: "localhost:2224"
cluster: {
  listen: "localhost:3334"
  routes: ["nats://localhost:4333"]
}
streaming: {
  store: "file"
  dir: "/tmp/stan-cluster/data"
  ft_group: "ft"
}

test.js

const STAN = require('node-nats-streaming')
let interval;
const sc = STAN.connect("test-cluster", "me")
sc.on('error', (err) => {
  console.error(err);
})
sc.on('connection_lost', () => {
  console.log('stan connection was lost!')
})
sc.on('close', () => {
  clearInterval(interval)
  console.log('closed')
})
sc.on('connect', () => {
  console.log(`connected to ${sc.nc.currentServer.url}`)
  const sub = sc.subscribe("test")
  sub.on('message', (msg) => {
    console.log(`[${msg.getSequence()}]: ${msg.getData()}`)
  })

  let count = 0;
  interval = setInterval(()=>{

    sc.publish('test', `${++count}`)
  }, 1000)
})

sc.on('disconnect', () => {
  console.log('disconnected')
})

sc.on('reconnect', () => {
  console.log(`reconnected to ${sc.nc.currentServer.url}`)
})