Уже лучше, теперь дальше - как выглядит коннектор к реббиту?

если он из переменных окружения берет реквизиты - то покажите их

async waitForConnection(interval = 1000, maxRetry) { console.log('... connecting to Queue ...') if (maxRetry > 0) { if (this.retry > maxRetry) { throw new Error('Exceeded Max Retry. Exiting ...') } this.retry++ } try { await this.connect() console.log('... connected to Queue ...') } catch (err) { console.log('Could not connect to Queue, retrying...') await this.wait(interval) await this.waitForConnection(maxRetry) } } async wait(time) { return new Promise((resolve) => setTimeout(resolve, time)) } async connect() { // connect to rabbitmq this.connection = await amqplib.connect(this.connectionString) // create connection this.channel = await this.connection.createChannel() // create exchange await this.channel.assertExchange(this.exchangeName, this.exchangeType, { durable: this.exchangeDurable, }) // create queue await this.channel.assertQueue(this.queueName, { durable: this.queueDurable, }) // set prefetch count this.channel.prefetch(this.prefetchCount) // bind queue to exchange await this.channel.bindQueue( this.queueName, this.exchangeName, this.routingKey ) return null } создание коннекта let RmqNotifications = await RMQConn({ exchangeType: 'direct', exchangeName: 'notifications', queueName: 'notifications', routingKey: 'notifications', })

connectionString как выглядит?

const connectionString = `amqp://${user}:${pass}@${host}:${port}` из ENV данные

Стикер

module.exports.RMQConn = async function (initObj) { try { if (!instance) { instance = new QueueClient(initObj) await instance.waitForConnection(1000) } return instance } catch (err) { console.log(err.message) } } создание коннекта let RmqNotifications = await RMQConn({ exchangeType: 'direct', exchangeName: 'notifications', queueName: 'notifications', routingKey: 'notifications', })

Стикер

хм.. странно. Думал что если сеть отваливается amqplib в on disconnect сообщить должна об этом, а вот выходит что нифига не так.. но я понял, пойду переписывать

Стикер

вот такое есть this.connection.on('connect', () => { console.log('Connected!') }) this.connection.on('disconnect', (params) => { console.log('Disconnected: ', params.err) }) this.connection.on('connectFailed', (params) => { console.log('connectFailed: ', params) }) this.connection.on('unblocked', () => { console.log('Unblocked') }) this.connection.on('blocked', (params) => { console.log('Blocked, reason: ', params.reason) })

А что за либа?

черт, сори, я перепутал либы )))) думал такое есть в amqplib, а он оесть только в amqp-connection-manager наверное ее проще заюзать будет, чем с нуля писать

Стикер

а с чем это связано? разрушение каналов имею ввиду архитектура самого кролика? или внешние факторы?

С сетью, с опоздавшими хэртбитами, с проксей, если она стоит перед кроликом, с протоколом (например, если произошло исключение в процессе работы с каналом, то с ним уже ничего сделать нельзя).

понял, взял на заметку

А куда деваться, это нода, там единственный рекомендуемый клиент и тот без 1.0 версии в 2024м

Стикер

Ну нода в целом в плане экосистемы по нулям

Есть там и свои либы, аналогов которым нет. Скажем, лучше, чем жс, мы не нашли либы для рендера пдф, работы с браузером и даже для работы с smpp (не smtp).

На дотнетике есть божественные либы для пдф, даже в годы до неткора. Но может у вас конечно особые кейсы были

У нас в принципе дотнета никогда не было.

И зря!)

Да ну, он же специфический. Только под винду работает(л) (или уже нет?). Там только NServiceBus крутой, как я знаю, многие по нему джавовские либы пилили.

Классика :D