nest-nats-management

Overview

This package provides a NestJS module for integrating with NATS Streaming (STAN), enabling publish-subscribe messaging in a microservices architecture. It offers automatic connection management, message publishing, and subscription handling with manual acknowledgment support.

Features

• 📡 Seamless NATS Streaming Integration
• 🔄 Automatic Reconnection Handling
• ✅ Manual Acknowledgment Support
• ⚡ Efficient Pub/Sub Mechanism
• 🚀 Easy to Use in Any NestJS Application

Installation

Install the package using npm:

1npm install nest-nats-management

Usage

1️⃣ Importing the Module in AppModule

1import { Module } from '@nestjs/common';
2import { NatsManagementModule } from 'nest-nats-management';
3
4@Module({
5  imports: [NatsManagementModule.forRoot('test-cluster', 'client-123', 'nats://localhost:4222')],
6})
7export class AppModule {}

2️⃣ Publishing Messages

1import { Injectable } from '@nestjs/common';
2import { NatsManagementService } from 'nest-nats-management';
3
4@Injectable()
5export class PersonnesService {
6  constructor(private readonly natsService: NatsManagementService) {}
7
8  async create(person: CreatePersonnesDto) {
9    //Your logic here
10
11    //publishing message
12    await this.natsService.publish('person:created', person);
13  }
14
15  
16}

3️⃣ Subscribing to Messages

1import { Controller } from '@nestjs/common';
2import { NatsManagementService } from 'nest-nats-management';
3
4@Controller('personnes')
5export class PersonnesController {
6  constructor(private readonly natsService: NatsManagementService) {
7    this.subscribeToPersonCreated();
8  }
9
10  private subscribeToPersonCreated() {
11    this.natsService.subscribe('person:created', (message) => {
12      console.log('📩 Received event in controller: person.created', message);
13      //message reatment here
14    });
15  }
16}
17

4️⃣ Unsubscribing from a Subject

1this.natsService.unsubscribe('person:created');

License

This project is licensed under the ISC License.