redis-streams-broker - npm Package Compare versions

Comparing version 0.0.14 to 0.0.15

index.d.ts


		export declare class StreamChannelBroker {
		constructor(redisClient: any, channelName: string);
		publish(payload: any, maximumApproximateMessages?: number, failOnMaxMessageCount: boolean): Promise<string>;
		publish(payload: any, maximumApproximateMessages?: number, failOnMaxMessageCount?: boolean): Promise<string>;
		destroy(): Promise<boolean>;
		@@ -6,0 +6,0 @@ joinConsumerGroup(groupName: string, readFrom: string): Promise<ConsumerGroup>;

package.json

		{
		"name": "redis-streams-broker",
		"version": "0.0.14",
		"version": "0.0.15",
		"description": "This package is a broker to redis stream data type, This package provides guaranteed message delivery feature with acknowledgement.",
		@@ -8,6 +8,7 @@ "main": "index.js",
		"mocha": "mocha",
		"test": "npm run redisstart && npm run mocha && npm run redisstop && npm run redisstart && env REDISCLIENT=1 npm run mocha && npm run redisstop",
		"test": "npm run redisstart && npm run mocha && npm run redisstop && npm run redisstart && npm run redisstop",
		"redisstop": "docker stop streamz",
		"redisstart": "npm run redisstop \|\| node -v && docker run --name streamz -p 6379:6379 -itd --rm redis:latest",
		"rediscli": "docker exec -it streamz redis-cli"
		"rediscli": "docker exec -it streamz redis-cli",
		"push": "npm whoami && npm version patch && npm test && npm publish && git push --tags"
		},
		@@ -14,0 +15,0 @@ "repository": {

readme.md

		@@ -5,3 +5,3 @@ # redis-streams-broker
		1. Broker to redis stream which can be used as centralized que between microservices. (Using Redis)
		2. Support for injectable redis client (be it [ioredis](https://www.npmjs.com/package/ioredis) or [redis](https://www.npmjs.com/package/redis))
		2. Support for injectable redis client [ioredis](https://www.npmjs.com/package/ioredis)only
		3. Guarantee of message delivery via consumer acknowledgements.
		@@ -83,3 +83,3 @@ 4. Consumer Group functionality for scalability. (Just like Kafka)
		## Current Version:
		0.0.13[Beta]
		0.0.15[Beta]

		@@ -86,0 +86,0 @@ ## License

New alerts