@n0tify/subscriber v0.0.10

@n0tify/subscriber

• Listens on socket, RabbitMQ, Kafka, redis or other exchange service
• Processes received message

Usage

import { Subsciber } from '@n0tify/subscriber';

const transport = ...;

const smsChannel = ...;

const subscriber = new Subscriber({
  transport,
  channels: [smsChannel]
});

await subscriber.listen();

Each message is processed by individual channels.

Further information

CLICK HERE for information about channels and transports