@nestjs-plugins/nestjs-nats-streaming-transport
Advanced tools
Comparing version 1.0.18 to 1.0.19
@@ -5,2 +5,3 @@ import { ModuleMetadata } from '@nestjs/common/interfaces'; | ||
export interface TransportSubscriptionOptions { | ||
ackWait?: number; | ||
deliverAllAvailable?: boolean; | ||
@@ -7,0 +8,0 @@ durableName?: string; |
@@ -5,4 +5,5 @@ "use strict"; | ||
exports.buildSubscriptionOptions = (transportSubscriptionOptions, connection) => { | ||
const { startAt, deliverAllAvailable, durableName, manualAckMode, maxInFligth, startAtSequence, startAtTimeDelta, startTime, startWithLastReceived, } = transportSubscriptionOptions; | ||
const { ackWait, startAt, deliverAllAvailable, durableName, manualAckMode, maxInFligth, startAtSequence, startAtTimeDelta, startTime, startWithLastReceived, } = transportSubscriptionOptions; | ||
const opts = connection.subscriptionOptions(); | ||
ackWait && opts.setAckWait(ackWait); | ||
startAt && opts.setStartAt(startAt); | ||
@@ -9,0 +10,0 @@ deliverAllAvailable && opts.setDeliverAllAvailable(); |
{ | ||
"name": "@nestjs-plugins/nestjs-nats-streaming-transport", | ||
"version": "1.0.18", | ||
"version": "1.0.19", | ||
"description": "Nats Streaming Transport for NestJS", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
@@ -60,3 +60,4 @@ # Nats Streaming Transport Module for NestJS | ||
## TransportSubscriptionOptions | ||
## TransportSubscriptionOptions | ||
- **ackWait** (number, default: 30 * 1000) - Attempt redelivery of the message if an acknowledgement is not received within the configured timeout interval. | ||
- **deliverAllAvailable** (string, default: false) - Receive all stored values in order | ||
@@ -63,0 +64,0 @@ - **durableName** (string, default: "") - Track the last acknowledged message for that clientID + durable name. Only messages since the last acknowledged message will be delivered to the client. |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Copyleft License
License(Experimental) Copyleft license information was found.
Found 1 instance in 1 package
Mixed license
License(Experimental) Package contains multiple licenses.
Found 1 instance in 1 package
Non-permissive License
License(Experimental) A license not known to be considered permissive was found.
Found 1 instance in 1 package
0
100
326
215
350119