Skip to content

Commit

Permalink
Build Files (#239)
Browse files Browse the repository at this point in the history
Co-authored-by: teammemphis <[email protected]>
  • Loading branch information
github-actions[bot] and teammemphis authored Jan 1, 2024
1 parent fd5d612 commit 0e332dc
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion lib/consumer.js
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ class Consumer {
this.partitionsGenerator = new memphis_1.RoundRobinProducerConsumerGenerator(partitions);
}
this.subscription = this.connection.brokerManager
.subscribe(`$memphis_dls_${this.internalStationName}_${this.internalConsumerGroupName}`, {
.subscribe(`$memphis_dls_${this.internalStationName}.${this.internalConsumerGroupName}`, {
queue: `$memphis_${this.internalStationName}_${this.internalConsumerGroupName}`
});
this._handleAsyncIterableSubscriber(this.subscription, true);
Expand Down
2 changes: 1 addition & 1 deletion lib/tsconfig.build.tsbuildinfo

Large diffs are not rendered by default.

0 comments on commit 0e332dc

Please sign in to comment.