function send(err, s3Url) {
          if (err) {
            debug(err);
            channel.sendToQueue(msg.properties.replyTo, encode(err), {
              correlationId: msg.properties.correlationId
            });
          } else {
            channel.sendToQueue(
              msg.properties.replyTo,
              encode({ url: s3Url }),
              {
                correlationId: msg.properties.correlationId
              }
            );
          }

          // Restart loop
          setTimeout(function() {
            debug("no message, waiting...");
            channel.ack(msg);
            consume();
          }, 1e3);
        }
/**
         * send - Sends the processed video back to the publisher in the form of a url to the
         * upload. Currently this is a url to an AWS s3 bucket hosted video.
         * The replyTo
         *
         * @param {string} err Any errors from processing
         * @param {type} s3Url Location of the uploaded video
         */
Sends the processed video back to the publisher in the form of a url to the
upload. Currently this is a url to an AWS s3 bucket hosted video.
The replyTo

@param {string} err Any errors from processing
@param {type} s3Url Location of the uploaded video
Sends the processed video back to the publisher in the form of a url to the upload . Currently this is a url to an AWS s3 bucket hosted video . The replyTo @param { string } err Any errors from processing @param { type } s3Url Location of the uploaded video
function send(err, s3Url) {
          if (err) {
            debug(err);
            channel.sendToQueue(msg.properties.replyTo, encode(err), {
              correlationId: msg.properties.correlationId
            });
          } else {
            channel.sendToQueue(
              msg.properties.replyTo,
              encode({ url: s3Url }),
              {
                correlationId: msg.properties.correlationId
              }
            );
          }
          setTimeout(function() {
            debug("no message, waiting...");
            channel.ack(msg);
            consume();
          }, 1e3);
        }
function send ( err , s3Url ) { if ( err ) { debug ( err ) ; channel . sendToQueue ( msg . properties . replyTo , encode ( err ) , { correlationId : msg . properties . correlationId } ) ; } else { channel . sendToQueue ( msg . properties . replyTo , encode ( { url : s3Url } ) , { correlationId : msg . properties . correlationId } ) ; } setTimeout ( function ( ) { debug ( "no message, waiting..." ) ; channel . ack ( msg ) ; consume ( ) ; } , 1e3 ) ; }
send - Sends the processed video back to the publisher in the form of a url to the
 upload.
send - Sends the processed video back to the publisher in the form of a url to the upload .
// Restart loop