Нет исключений, когда node-amqp

Я пытаюсь использовать node-amqp.

Когда в разделе соединения с кроликом выдается исключение, я могу получить это исключение, но оно навсегда перезапускает соединение с Кроликом.

Посмотри на это:

    amqp = require("amqp")

    # Open a connection
    conn = amqp.createConnection( {url: "amqp://localhost"} , {reconnect: true})

    conn.on "ready", ->
      console.log "Conn Ready"

      conn.queue "queueX", {ack:true}, (queue) ->
        console.log "Subscribed #{queue.name}"

        assdsd() #calling non-exiting method. No exception is thrown but the connection is restarted

Система зацикливается на сгенерированных ошибках. Я знаю, что это из-за {recconnect:true}. Но я хотел бы иметь возможность ловить исключения самостоятельно. Любая идея?

Вывод моего скрипта выглядит так:

Conn Ready
Subscribed queueX
Conn Ready
Subscribed queueX
Conn Ready
Subscribed queueX
Conn Ready
Subscribed queueX
Conn Ready
Subscribed queueX
Conn Ready
Subscribed queueX
....

1 ответ

Решение

Возможно, у вас где-то есть ошибка, это может вам помочь

# listen for conn errors
conn.on 'error', (err) ->
  # print to check what went wrong
  console.error err.stack

  # exit script with error
  # http://nodejs.org/api/process.html#process_process_exit_code
  process.exit 1
Другие вопросы по тегам