Nodejs使用cluster，fork了4个instance出来

原先的代码

  socket.emit("chat", {message:'aa'},callback)

现在使用了redis pub/sub

this.pub.publish('chat', JSON.stringify(message))

 this.sub.on('message', function(channel, message) {
  //这里我怎么获取到之前的callback呢？
  socket.emit(channel, message);
 });

问题如上，我怎么在publish是把原本客户端传过来的callback一并带过去呢？