         cb false, @getChannelNameForKite()
 
       'kite.join': (opts, cb)->
-        console.log "========>>>>>>"
-        console.log "opts", opts
-
         channelName = opts.args[0]
-        kiteName = opts.args[1]
+        kiteName    = opts.args[1]
         if not @kiteList[channelName]
           @kiteList[channelName] = []
         if kiteName not in @kiteList[channelName] 
           @kiteList[channelName].push kiteName
         console.log "clients", @kiteList
-        cb false, true
-
-      'kite.consume': ()->
+        if cb
+          cb false, true
+
+      'kite.consume': (opts, cb)->
         # TODO:
         @mergenData.lpop @getChannelNameForGenericName(), (err, val)->
           console.log "!!!!!!!!!!!!! lpop lpop >>>>>>", val


    @mergenData.hset "#{@publicKey}-kites", "#{@serviceGenericName}-#{@serviceUniqueName}", data

    @sendCommand @getChannelNameForGenericName(), "kite.who", [], (reply)->
      @commands['kite.join'].call(@, @getChannelNameForGenericName(), reply)

    @sendCommand @getChannelNameForGenericName(), "kite.join", [@getChannelNameForGenericName(), @getChannelNameForKite()]


    @mergen.subscribe @getChannelNameForKite()

    @mergen.on "message", (channel, message)=>
      message = JSON.parse message
      @receivedCommand message.from, message.id, message.cmd, message.args

