Skip to content

Commit fa2a33f

Browse files
authored
feat: Add new option in get listener logic (#106)
1 parent bb8c4ae commit fa2a33f

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

src/StreamManager.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -91,6 +91,10 @@ export class StreamManager extends Root {
9191
.maxAckPending(setting?.maxPending || 10)
9292
.deliverTo(createInbox());
9393

94+
if (setting?.maxAckWaiting) {
95+
options.maxWaiting(setting.maxAckWaiting);
96+
}
97+
9498
if (setting?.queue) {
9599
options.queue(setting.queue);
96100
}

src/interfaces.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,7 @@ export interface GetListenerOptions {
8484
queue?: string;
8585
deliver?: 'all' | 'new';
8686
maxPending?: number;
87+
maxAckWaiting?: number
8788
}
8889

8990
export interface StreamManagerParam {

0 commit comments

Comments
 (0)