[Groonga-commit] groonga/express-kotoumi [master] Create handler for published messages with its name

Back to archive index

YUKI Hiroshi null+****@clear*****
Thu Feb 7 18:33:59 JST 2013


YUKI Hiroshi	2013-02-07 18:33:59 +0900 (Thu, 07 Feb 2013)

  New Revision: 751247a74e045cde9b81a60d8cf40caa24eb2c59
  https://github.com/groonga/express-kotoumi/commit/751247a74e045cde9b81a60d8cf40caa24eb2c59

  Log:
    Create handler for published messages with its name

  Modified files:
    lib/frontend/socket.io-adaptor.js
    test/frontend-socket.io-adaptor.test.js

  Modified: lib/frontend/socket.io-adaptor.js (+1 -1)
===================================================================
--- lib/frontend/socket.io-adaptor.js    2013-02-07 18:30:59 +0900 (a619999)
+++ lib/frontend/socket.io-adaptor.js    2013-02-07 18:33:59 +0900 (88e5742)
@@ -117,7 +117,7 @@ exports.register = function(application, server, params) {
                 createClientMessageHandler(command.name, socket));
 
       if (model.isA(command.definition, model.PublishSubscribe)) {
-        var publishedMessageHandler = createPublishedMessageHandler(socket);
+        var publishedMessageHandler = createPublishedMessageHandler(command.name, socket);
         connection.on(command.name, publishedMessageHandler);
       }
     });

  Modified: test/frontend-socket.io-adaptor.test.js (+1 -1)
===================================================================
--- test/frontend-socket.io-adaptor.test.js    2013-02-07 18:30:59 +0900 (a629df8)
+++ test/frontend-socket.io-adaptor.test.js    2013-02-07 18:33:59 +0900 (7fcb98a)
@@ -190,7 +190,7 @@ suite('Socket.IO API', function() {
           statusCode: 200,
           body:       { published: true}
         };
-        connection.controllers.search.trigger(envelope);
+        connection.controllers.pubsub.trigger(envelope);
       })
       .wait(0.01)
       .next(function() {
-------------- next part --------------
HTML����������������������������...
Download 



More information about the Groonga-commit mailing list
Back to archive index