Comparing version 0.1.3 to 0.2.0
@@ -30,6 +30,11 @@ var Engine = function(server, options) { | ||
this._messageChannel = this._ns + '/notifications/messages'; | ||
this._closeChannel = this._ns + '/notifications/close'; | ||
var self = this; | ||
this._subscriber.subscribe(this._ns + '/notifications'); | ||
this._subscriber.subscribe(this._messageChannel); | ||
this._subscriber.subscribe(this._closeChannel); | ||
this._subscriber.on('message', function(topic, message) { | ||
self.emptyQueue(message); | ||
if (topic === self._messageChannel) self.emptyQueue(message); | ||
if (topic === self._closeChannel) self._server.trigger('close', message); | ||
}); | ||
@@ -101,2 +106,3 @@ | ||
self._server.trigger('disconnect', clientId); | ||
self._redis.publish(self._closeChannel, clientId); | ||
if (callback) callback.call(context); | ||
@@ -152,3 +158,3 @@ }); | ||
self._redis.rpush(queue, jsonMessage); | ||
self._redis.publish(self._ns + '/notifications', clientId); | ||
self._redis.publish(self._messageChannel, clientId); | ||
@@ -155,0 +161,0 @@ self.clientExists(clientId, function(exists) { |
@@ -6,8 +6,9 @@ { "name" : "faye-redis" | ||
, "keywords" : ["pubsub", "bayeux"] | ||
, "license" : "MIT" | ||
, "version" : "0.1.3" | ||
, "version" : "0.2.0" | ||
, "engines" : {"node": ">=0.4.0"} | ||
, "main" : "./faye-redis" | ||
, "dependencies" : {"redis": ""} | ||
, "devDependencies" : {"jsclass": ""} | ||
, "devDependencies" : {"jstest": ""} | ||
@@ -18,12 +19,6 @@ , "scripts" : {"test": "node spec/runner.js"} | ||
, "licenses" : [ { "type" : "MIT" | ||
, "url" : "http://www.opensource.org/licenses/mit-license.php" | ||
} | ||
] | ||
, "repositories" : [ { "type" : "git" | ||
, "url" : "git://github.com/faye/faye-redis-node.git" | ||
} | ||
] | ||
, "repository" : { "type" : "git" | ||
, "url" : "git://github.com/faye/faye-redis-node.git" | ||
} | ||
} | ||
@@ -5,4 +5,4 @@ # faye-redis [![Build Status](https://secure.travis-ci.org/faye/faye-redis-node.png)](http://travis-ci.org/faye/faye-redis-node) | ||
[Faye](http://faye.jcoglan.com) messaging server. It allows a single Faye | ||
service to be distributed across many front-end web servers by storing state | ||
and routing messages through a [Redis](http://redis.io) database server. | ||
service to be distributed across many front-end web servers by storing state and | ||
routing messages through a [Redis](http://redis.io) database server. | ||
@@ -54,5 +54,5 @@ | ||
the Software without restriction, including without limitation the rights to | ||
use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies | ||
of the Software, and to permit persons to whom the Software is furnished to do | ||
so, subject to the following conditions: | ||
use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of | ||
the Software, and to permit persons to whom the Software is furnished to do so, | ||
subject to the following conditions: | ||
@@ -63,8 +63,7 @@ The above copyright notice and this permission notice shall be included in all | ||
THE SOFTWARE IS PROVIDED 'AS IS', WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE | ||
SOFTWARE. | ||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS | ||
FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR | ||
COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER | ||
IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN | ||
CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. | ||
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
No repository
Supply chain riskPackage does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.
Found 1 instance in 1 package
11407
193
0
67