ocbesbn-redis-events
Advanced tools
Comparing version 1.0.5 to 1.0.6
15
index.js
@@ -228,3 +228,3 @@ 'use strict' | ||
{ | ||
var logger = new Logger({ context : { serviceName : configService.serviceName } }); | ||
const logger = new Logger({ context : { serviceName : configService.serviceName } }); | ||
@@ -242,11 +242,16 @@ return configService.init({ host : config.consul.host }).then(consul => | ||
{ | ||
var client = redis.createClient({ | ||
const client = redis.createClient({ | ||
host : props.ep.host, | ||
port : props.ep.port, | ||
password : props.password | ||
password : props.password, | ||
connection_strategy : (info) => 1000, | ||
retry_strategy : (info) => 1000 | ||
}); | ||
client.on('ready', () => resolve(client)); | ||
client.on('error', err => reject(err)); | ||
client.on('retry_strategy', info => 1000); | ||
client.on('error', err => | ||
{ | ||
logger.error(err); | ||
reject(err); | ||
}); | ||
}); | ||
@@ -253,0 +258,0 @@ }) |
{ | ||
"name": "ocbesbn-redis-events", | ||
"version": "1.0.5", | ||
"version": "1.0.6", | ||
"description": "Module simplifying access to the publish/subscribe system provided by Redis.", | ||
@@ -34,7 +34,7 @@ "main": "index.js", | ||
"dependencies": { | ||
"bluebird": "^3.5.0", | ||
"extend": "^3.0.0", | ||
"ocbesbn-config": "^2.2.5", | ||
"ocbesbn-logger": "^1.0.3", | ||
"redis": "^2.7.1" | ||
"bluebird": "^3.5.1", | ||
"extend": "^3.0.1", | ||
"ocbesbn-config": "^2.2.11", | ||
"ocbesbn-logger": "^1.0.5", | ||
"redis": "^2.8.0" | ||
}, | ||
@@ -41,0 +41,0 @@ "devDependencies": { |
@@ -41,3 +41,3 @@ <a name="RedisEvents"></a> | ||
**Kind**: instance method of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: instance method of [<code>RedisEvents</code>](#RedisEvents) | ||
**Returns**: <code>Promise</code> - [Promise](http://bluebirdjs.com/docs/api-reference.html) resolving with true if the subscription succeeded. Otherwise false or an error. | ||
@@ -55,3 +55,3 @@ | ||
**Kind**: instance method of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: instance method of [<code>RedisEvents</code>](#RedisEvents) | ||
**Returns**: <code>Promise</code> - [Promise](http://bluebirdjs.com/docs/api-reference.html) resolving with true or false. | ||
@@ -68,3 +68,3 @@ | ||
**Kind**: instance method of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: instance method of [<code>RedisEvents</code>](#RedisEvents) | ||
**Returns**: <code>Promise</code> - [Promise](http://bluebirdjs.com/docs/api-reference.html) resolving with true or false if there was no active connection. | ||
@@ -82,3 +82,3 @@ <a name="RedisEvents+emit"></a> | ||
**Kind**: instance method of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: instance method of [<code>RedisEvents</code>](#RedisEvents) | ||
**Returns**: <code>Promise</code> - [Promise](http://bluebirdjs.com/docs/api-reference.html) resolving with true when the event was published or rejecting with an error. | ||
@@ -96,3 +96,3 @@ | ||
**Kind**: instance method of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: instance method of [<code>RedisEvents</code>](#RedisEvents) | ||
**Returns**: <code>Promise</code> - [Promise](http://bluebirdjs.com/docs/api-reference.html) resolving with true or false if there was no active connection. | ||
@@ -104,3 +104,3 @@ <a name="RedisEvents+disposeAll"></a> | ||
**Kind**: instance method of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: instance method of [<code>RedisEvents</code>](#RedisEvents) | ||
**Returns**: <code>Promise</code> - [Promise](http://bluebirdjs.com/docs/api-reference.html) resolving with two results. | ||
@@ -114,3 +114,3 @@ <a name="RedisEvents+contextify"></a> | ||
**Kind**: instance method of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: instance method of [<code>RedisEvents</code>](#RedisEvents) | ||
<a name="RedisEvents+hasSubscription"></a> | ||
@@ -123,3 +123,3 @@ | ||
**Kind**: instance method of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: instance method of [<code>RedisEvents</code>](#RedisEvents) | ||
**Returns**: <code>boolean</code> - Returns true if the *channel* is already registered; otherwise false. | ||
@@ -131,3 +131,3 @@ <a name="RedisEvents.DefaultConfig"></a> | ||
**Kind**: static property of <code>[RedisEvents](#RedisEvents)</code> | ||
**Kind**: static property of [<code>RedisEvents</code>](#RedisEvents) | ||
**Properties** | ||
@@ -143,4 +143,4 @@ | ||
| consul.redisServiceName | <code>object</code> | Name of the enpoint for the Redis server in consul. | | ||
| consul.redisPasswordKey | <code>object</code> | Consul configuration key for Redis authorisation. | | ||
| consul.redisPasswordKey | <code>object</code> | Consul configuration key for Redis authorisation. Might be null or false if not desired to be used. | | ||
| context | <code>object</code> | Optional context object to automatically extend emitted messages. | | ||
33590
12
534
Updatedbluebird@^3.5.1
Updatedextend@^3.0.1
Updatedocbesbn-config@^2.2.11
Updatedocbesbn-logger@^1.0.5
Updatedredis@^2.8.0