@nestjs-plugins/nestjs-nats-jetstream-transport
Advanced tools
Comparing version 1.1.0 to 1.1.1
{ | ||
"name": "@nestjs-plugins/nestjs-nats-jetstream-transport", | ||
"version": "1.1.0", | ||
"version": "1.1.1", | ||
"description": "Nats JetStream Transport for NestJS", | ||
@@ -44,3 +44,3 @@ "main": "dist/index.js", | ||
}, | ||
"gitHead": "6d901b84b42e304c45e00e60713886d117960d65" | ||
"gitHead": "6b02cc995ef151cf3f1e0e5dc83a3e13e535825c" | ||
} |
@@ -170,2 +170,3 @@ # 🚀 Nats JetStream Transport Module for NestJS | ||
import { PubAck } from 'nats'; | ||
import { Observable } from 'rxjs'; | ||
@@ -235,3 +236,3 @@ interface OrderCreatedEvent { | ||
import { Controller, Get } from '@nestjs/common'; | ||
import { Ctx, EventPattern, Payload } from '@nestjs/microservices'; | ||
import { Ctx, EventPattern, MessagePattern, Payload } from '@nestjs/microservices'; | ||
import { AppService } from './app.service'; | ||
@@ -318,3 +319,3 @@ | ||
connectionOptions: { | ||
servers: 'localhost' | ||
servers: 'localhost:4222', | ||
name: 'myservice-listener' | ||
@@ -324,3 +325,3 @@ }, | ||
deliverGroup: 'myservice-group', | ||
durable: true, | ||
durable: 'myservice', | ||
deliverTo: 'myservice', | ||
@@ -327,0 +328,0 @@ manualAck: true, |
136621
337