amqp / rhea

A reactive messaging library based on the AMQP protocol
Apache License 2.0
273 stars 80 forks source link

loosing messages intermittently while consuming from Azure service bus #402

Open manisrivastav opened 1 year ago

manisrivastav commented 1 year ago

we were using RHEA amqp v1.0.9 from many years, we recently started seeing that messages are missing intermittently on the receiver end.

tried adding some logging with events, but no luck

on receiver side added below events to capture.

    receiver.on('receiver_close', (e) => {
        winston.error('Rhea receiver was closed?', e);
    });

    receiver.on('error', (e) => {
        winston.error('Rhea receiver was closed?', e);
    });

    receiver.on('receiver_error', (e) => {
        winston.error('Rhea receiver error?', e);
    });

added similar logging on container level

container.on('connection_close', () => { winston.error('connection_close'); });

container.on('connection_error', (e) => { winston.error('connection_error', e); });

container.on('protocol_error', (e) => { winston.error('protocol_error', e); });

container.on('error', (e) => { winston.error('error', e); });

grs commented 1 year ago

What do you mean by 'missing'? There are messages sent that don't seem to be received? I would suggest that you ask the Azure Service Bus support team for any information they can give.

(You can set env var DEBUG=rhea* to get very detailed logging, but that may be too much if the issue is intermittent.)