mqemitter-redis
Advanced tools
Comparing version 4.0.1 to 4.0.2
@@ -118,3 +118,3 @@ 'use strict' | ||
.replace(this._opts.regexWildcardOne, '*') | ||
.replace(this._opts.wildcardSome, '*') | ||
.replace((this._opts.matchEmptyLevels ? this._opts.separator : '') + this._opts.wildcardSome, '*') | ||
} | ||
@@ -134,3 +134,3 @@ | ||
this._topics[subTopic]++ | ||
onFinish() | ||
onFinish.call(this) | ||
return this | ||
@@ -142,5 +142,5 @@ } | ||
if (this._containsWildcard(topic)) { | ||
this.subConn.psubscribe(subTopic, onFinish) | ||
this.subConn.psubscribe(subTopic, onFinish.bind(this)) | ||
} else { | ||
this.subConn.subscribe(subTopic, onFinish) | ||
this.subConn.subscribe(subTopic, onFinish.bind(this)) | ||
} | ||
@@ -147,0 +147,0 @@ |
{ | ||
"name": "mqemitter-redis", | ||
"version": "4.0.1", | ||
"version": "4.0.2", | ||
"description": "Redis-based MQEmitter", | ||
@@ -12,3 +12,3 @@ "main": "mqemitter-redis.js", | ||
"lru-cache": "^5.1.1", | ||
"mqemitter": "^4.1.2", | ||
"mqemitter": "^4.1.3", | ||
"msgpack-lite": "^0.1.14" | ||
@@ -15,0 +15,0 @@ }, |
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
9367
1
Updatedmqemitter@^4.1.3