lib/amqp/queue.js
function getNoBatchOps(raw) {
    messages.receivedCount += 1;

    return {
      ack: function() {
        qLog.debug(`Acking tag ${raw.fields.deliveryTag} on ${messages.name} - ${messages.connectionName}`);
        channel.ack({ fields: { deliveryTag: raw.fields.deliveryTag } }, false);
      },
      nack: function() {
        qLog.debug(`Nacking tag ${raw.fields.deliveryTag} on ${messages.name} - ${messages.connectionName}`);
        channel.nack({ fields: { deliveryTag: raw.fields.deliveryTag } }, false);
      },
      reject: function() {
        qLog.debug(`Rejecting tag ${raw.fields.deliveryTag} on ${messages.name} - ${messages.connectionName}`);
        channel.nack({ fields: { deliveryTag: raw.fields.deliveryTag } }, false, false);
      }
    };
  }
function getNoBatchOps(raw) {
    messages.receivedCount += 1;

    return {
      ack: function() {
        qLog.debug(`Acking tag ${raw.fields.deliveryTag} on ${messages.name} - ${messages.connectionName}`);
        channel.ack({ fields: { deliveryTag: raw.fields.deliveryTag } }, false);
      },
      nack: function() {
        qLog.debug(`Nacking tag ${raw.fields.deliveryTag} on ${messages.name} - ${messages.connectionName}`);
        channel.nack({ fields: { deliveryTag: raw.fields.deliveryTag } }, false);
      },
      reject: function() {
        qLog.debug(`Rejecting tag ${raw.fields.deliveryTag} on ${messages.name} - ${messages.connectionName}`);
        channel.nack({ fields: { deliveryTag: raw.fields.deliveryTag } }, false, false);
      }
    };
  }
function getNoBatchOps ( raw ) { messages . receivedCount += 1 ; return { ack : function ( ) { qLog . debug ( ` ${ raw . fields . deliveryTag } ${ messages . name } ${ messages . connectionName } ` ) ; channel . ack ( { fields : { deliveryTag : raw . fields . deliveryTag } } , false ) ; } , nack : function ( ) { qLog . debug ( ` ${ raw . fields . deliveryTag } ${ messages . name } ${ messages . connectionName } ` ) ; channel . nack ( { fields : { deliveryTag : raw . fields . deliveryTag } } , false ) ; } , reject : function ( ) { qLog . debug ( ` ${ raw . fields . deliveryTag } ${ messages . name } ${ messages . connectionName } ` ) ; channel . nack ( { fields : { deliveryTag : raw . fields . deliveryTag } } , false , false ) ; } } ; }
Get message operations for an unbatched queue
@private
Get message operations for an unbatched queue