@byteboost/nats-events v1.0.17

byteboost-nats-events

Nats events for Byteboost services

import { JsMsg } from 'nats';
import { Listener, Publisher } from './base';
import { Subjects, UserCreatedEvent } from './events';

class UserCreatedListener extends Listener<UserCreatedEvent> {
  subject: Subjects.UserCreated = Subjects.UserCreated;
  channelName: string = 'user';

  async onMessage(data: UserCreatedEvent['data'], message: JsMsg) {
    console.log(message, 23);

    message.ack();
  }
}

class UserCreatedPublisher extends Publisher<UserCreatedEvent> {
  subject: Subjects.UserCreated = Subjects.UserCreated;
  channelName: string = 'user';
}

const main = async () => {
  const nats = new Nats('task');
  await nats.connect('0.0.0.0:4222');

  new UserCreatedListener(nats.client).listen();

  new UserCreatedPublisher(nats.client).publish({
    type: 'task created',
    test: 'Second message!!',
  });
};

main();

TODO

• Server must be able to catch up and read old messages on server start even if they have been acknowledged