redis-streams-broker
Advanced tools
Comparing version 0.0.3 to 0.0.4
@@ -6,3 +6,3 @@ export declare class StreamChannelBroker { | ||
joinConsumerGroup(groupName: string, readFrom: string): Promise<ConsumerGroup>; | ||
}; | ||
} | ||
@@ -15,3 +15,3 @@ declare class ConsumerGroup { | ||
pendingSummary(): Promise<GroupSummary>; | ||
}; | ||
} | ||
@@ -18,0 +18,0 @@ declare class Payload { |
const redisType = require("ioredis"); | ||
const shortid = require("shortid"); | ||
module.exports = class StreamChannelBroker { | ||
class StreamChannelBroker { | ||
@@ -158,2 +158,4 @@ constructor(redisConnectionString, channelName) { | ||
} | ||
} | ||
exports.StreamChannelBroker = StreamChannelBroker; |
{ | ||
"name": "redis-streams-broker", | ||
"version": "0.0.3", | ||
"version": "0.0.4", | ||
"description": "This package is a broker to redis stream data type, This package provides guaranteed message delivery feature with acknowledgement.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
21947
374