lib/consumers/amqp.js
function stopAll(socket) {
  if (_.isEmpty(this.consumers)) {
    return;
  }

  _.forOwn(this.consumers[socket.id].routingKeys, function (consumer, routingKey) {
    if (routingKey == '#') {
      // this must be done to prevent infinite stop loop
      routingKey = '##';
    }

    this.stopConsume(socket, {routingKey: routingKey});
  }.bind(this));
}
function stopAll(socket) {
  if (_.isEmpty(this.consumers)) {
    return;
  }

  _.forOwn(this.consumers[socket.id].routingKeys, function (consumer, routingKey) {
    if (routingKey == '#') {
      // this must be done to prevent infinite stop loop
      routingKey = '##';
    }

    this.stopConsume(socket, {routingKey: routingKey});
  }.bind(this));
}
function stopAll ( socket ) { if ( _ . isEmpty ( this . consumers ) ) { return ; } _ . forOwn ( this . consumers [ socket . id ] . routingKeys , function ( consumer , routingKey ) { if ( routingKey == '#' ) { // this must be done to prevent infinite stop loop routingKey = '##' ; } this . stopConsume ( socket , { routingKey : routingKey } ) ; } . bind ( this ) ) ; }
Stop all consumers linked to a socket

@param socket
Stop all consumers linked to a socket