code: function getTopicQueue(name) {
    var self = this;
    var queue = self._topicQueues[name];
  
    if (!queue) {
      // XXX(sam) topic queues should know subscribers and their topics
      queue = self._topicQueues[name] = new EventEmitter();
      queue.publish = function(msg, topic) {
        // XXX(sam) sends to all workers, should only send to ones who subscribe
        // XXX(sam) send same obj to all workers, instead of recreating
        Object.keys(cluster.workers).forEach(function(id) {
          cluster.workers[id].send({
            name: name,
            type: 'publish',
            topic: String(topic),
            msg: msg
          });
        });
  
        queue.emit('publish', {
          topic: String(topic), // XXX(sam) why String?
          msg: msg
        });
      };
    }
  
    return queue;
  }
docs: ## _getTopicQueue `_getTopicQueue(name)`  Internal use only.  Returns the TopicQueue named **name**, creating one if it doesn't already exist.