     stack    : err.stack
 
   group: (groupName, cmd, args, callback)->
-    console.log "group:::", groupName, cmd, args, callback
-    console.log "publishing to:", @communicator.getGroupName(groupName)
+    # console.log "group:::", groupName, cmd, args, callback
+    # console.log "publishing to:", @communicator.getGroupName(groupName)
     @communicator.sendCommand @communicator.getGroupName(groupName), cmd, args, callback
 
   everyone: (cmd, args, callback)->


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

      # @queueCommand "hello", ["world"], (ret)->
      #   console.log "queue command returned"

    startQueueChecker = ()=>
      setInterval ()=>
        @commands['kite.consume']()
      , 10


    @sendCommand(from, "reply-#{cmdid}", ['function not found', false])


  queueCommand:(channel, cmd, args, cb=false)->

    if not channel
      channel = @getChannelNameForGenericName()
    else
      channel = @getChannelNameForGenericName(channel)

    # sendCommand broadcasts, with this one, we first push to queue
    # then broadcast and one of them consumes
    @callbackid++
    data = {
      cmd: cmd,
