Skip to content
CI - LavinMQ

Run CI against LavinMQ too #1

Sign in to view logs

Run CI against LavinMQ too

Run CI against LavinMQ too #1

Triggered via pull request April 13, 2026 11:33
@walrowalro
opened #201
ci/lavinmq
Status Failure
Total duration 1m 5s
Artifacts –

lavinmq.yml

on: pull_request
test-browser
1m 2s
test-browser
Matrix: test
Fit to window
Zoom out
Zoom in

Annotations

10 errors and 8 warnings
test-browser/amqp-session.ts > AMQPQueue.delete() removes the queue: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > AMQPQueue.purge() empties the queue: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > AMQPQueue.bind() and unbind(): src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > AMQPQueue.publish({ confirm: false }) sends without waiting for confirm: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > AMQPQueue.subscribe() async generator: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > AMQPQueue.subscribe() nack: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > AMQPQueue.subscribe() delivers messages via callback: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > AMQPQueue.publish() and get() round-trip: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > session.queue() declares a queue and returns AMQPQueue: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test-browser/amqp-session.ts > AMQPSession.connect() returns a session over WebSocket: src/amqp-base-client.ts#L330
AMQPError: connection closed: ACCESS_REFUSED - (403) ❯ AMQPWebSocketClient.parseFrames src/amqp-base-client.ts:330:30 ❯ AMQPWebSocketClient.handleMessage src/amqp-websocket-client.ts:177:15 ⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯ Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>', constructor: 'Function<TextEncoder>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/141.0.7390.37 Safari/537.36', channels: [ { consumers: { constructor: 'Function<Map>', get: 'Function<get>', set: 'Function<set>', has: 'Function<has>', delete: 'Function<delete>', clear: 'Function<clear>', entries: 'Function<entries>', forEach: 'Function<forEach>', keys: 'Function<keys>', size: +0, values: 'Function<values>' }, rpcQueue: 'Promise', rpcCallbacks: [], unconfirmedPublishes: [], closed: false, confirmId: +0, connection: [Circular], id: +0, onerror: 'Function<anonymous>', constructor: 'Function<AMQPChannel>', open: 'Function<open>', prefetch: 'Function<prefetch>', onReturn: 'Function<onReturn>', close: 'Function<close>', basicGet: 'Function<basicGet>', basicConsume: 'Function<basicConsume>', basicCancel: 'Function<basicCancel>', basicAck: 'Function<basicAck>', basicNack: 'Function<basicNack>', basicReject: 'Function<basicReject>', basicRecover: 'Function<basicRecover>', basicPublish: 'Function<basicPublish>', basicQos: 'Function<basicQos>', basicFlow: 'Function<basicFlow>', confirmSelect: 'Function<confirmSelect>', queueDeclare: 'Function<queueDeclare>', queueDelete: 'Function<queueDelete>', queueBind: 'Function<queueBind>', queueUnbind: 'Function<queueUnbind>', queuePurge: 'Function<queuePurge>', exchangeDeclare: 'Function<exchangeDeclare>', exchangeDelete: 'Function<exchangeDelete>', exchangeBind: 'Function<exchangeBind>', exchangeUnbind: 'Function<exchangeUnbind>', txSelect: 'Function<txSelect>', txCommit: 'Function<txCommit>', txRollback: 'Function<txRollback>', txMethod: 'Function<txMethod>', sendRpc: 'Function<sendRpc>', setClosed: 'Function<setClosed>', rejectClosed: 'Function<rejectClosed>', publishConfirmed: 'Function<publishConfirmed>', onMessageReady: 'Function<onMessageReady>', resolveRPC: 'Function<resolveRPC>', rejectRPC: 'Function<rejectRPC>', deliver: 'Function<deliver>' } ], onerror: 'Function<anonymous>', frameMax: 8192, heartbeat: +0, framePos: +0, frameSize: +0, url: 'ws://127.0.0.1:15672/', frameBuffer: { '0': +0, '1': +0, '2': +0, '3': +0, '4': +0, '5': +0, '6': +0, '7': +0, '8': +0, '9': +0, '10': +0, '11': +0, '12': +0, '13': +0, '14': +0, '15': +0, '16': +0, '17': +0, '18': +0, '19': +0, '20': +0, '21': +0, '22': +0, '23': +0, '24': +0, '25': +0, '26': +0, '27': +0, '28': +0, '29': +0, '30': +0, '31': +0, '32': +0, '33': +0, '34': +0, '35': +0, '36': +0, '37': +0, '38': +0, '39': +0, '40': +0, '41': +0, '42': +0, '43': +0, '44': +0, '45': +0, '46': +0, '47': +0, '48': +0, '49': +0, '50': +0, '51': +0, '52': +0, '53': +0, '54': +0, '55': +0, '56': +0, '57': +0, '58': +0, '59': +0, '60': +0, '61': +0, '62': +0, '63': +0, '64': +0, '65': +0, '66': +0, '67': +0, '68': +0, '69': +0, '70': +0, '71': +0, '72': +0, '73': +0, '74': +0, '75': +0, '76': +0, '77': +0, '78': +0, '79': +0, '80': +0, '81': +0, '82': +0, '83': +0, '84': +0, '85': +0, '86': +0, '87': +0, '88': +0, '89': +0, '90': +0, '91': +0, '92': +0, '93': +0, '94': +0, '95': +0, '96': +0, '97': +0, '98': +0, '99': +0, '100': +0, '101': +0, '102': +0, '103': +0, '104': +0, '105': +0, '106': +0, '107': +0, '108': +0, '109': +0, '110': +0, '111': +0, '112': +0, '113': +0, '114': +0, '115': +0, '116': +0, '117': +0, '118': +0, '119': +0, '120': +0, '121': +0, '122': +0, '123': +0, '124': +0, '125': +0, '126': +0, '127': +0, '128': +0, '129': +0, '130': +0, '131': +0, '132': +0, '133': +0, '134': +0, '135': +0, '136': +0, '137': +0, '138': +0, '139': +0, '140': +0, '141': +0, '142': +0, '143':
test (22.x)
Node.js 20 actions are deprecated. The following actions are running on Node.js 20 and may not work as expected: actions/checkout@v4. Actions will be forced to run with Node.js 24 by default starting June 2nd, 2026. Node.js 20 will be removed from the runner on September 16th, 2026. Please check if updated versions of these actions are available that support Node.js 24. To opt into Node.js 24 now, set the FORCE_JAVASCRIPT_ACTIONS_TO_NODE24=true environment variable on the runner or in your workflow file. Once Node.js 24 becomes the default, you can temporarily opt out by setting ACTIONS_ALLOW_USE_UNSECURE_NODE_VERSION=true. For more information see: https://github.blog/changelog/2025-09-19-deprecation-of-node-20-on-github-actions-runners/
test (22.x)
Homebrew/actions/setup-homebrew@master is deprecated. Please update your workflow references to use Homebrew/actions/setup-homebrew@main. The "master" branch sync will stop and this warning will become an error when Homebrew 5.2.0 is released (no earlier than 2026-06-10).
test (24.x)
Node.js 20 actions are deprecated. The following actions are running on Node.js 20 and may not work as expected: actions/checkout@v4. Actions will be forced to run with Node.js 24 by default starting June 2nd, 2026. Node.js 20 will be removed from the runner on September 16th, 2026. Please check if updated versions of these actions are available that support Node.js 24. To opt into Node.js 24 now, set the FORCE_JAVASCRIPT_ACTIONS_TO_NODE24=true environment variable on the runner or in your workflow file. Once Node.js 24 becomes the default, you can temporarily opt out by setting ACTIONS_ALLOW_USE_UNSECURE_NODE_VERSION=true. For more information see: https://github.blog/changelog/2025-09-19-deprecation-of-node-20-on-github-actions-runners/
test (24.x)
Homebrew/actions/setup-homebrew@master is deprecated. Please update your workflow references to use Homebrew/actions/setup-homebrew@main. The "master" branch sync will stop and this warning will become an error when Homebrew 5.2.0 is released (no earlier than 2026-06-10).
test (23.x)
Node.js 20 actions are deprecated. The following actions are running on Node.js 20 and may not work as expected: actions/checkout@v4. Actions will be forced to run with Node.js 24 by default starting June 2nd, 2026. Node.js 20 will be removed from the runner on September 16th, 2026. Please check if updated versions of these actions are available that support Node.js 24. To opt into Node.js 24 now, set the FORCE_JAVASCRIPT_ACTIONS_TO_NODE24=true environment variable on the runner or in your workflow file. Once Node.js 24 becomes the default, you can temporarily opt out by setting ACTIONS_ALLOW_USE_UNSECURE_NODE_VERSION=true. For more information see: https://github.blog/changelog/2025-09-19-deprecation-of-node-20-on-github-actions-runners/
test (23.x)
Homebrew/actions/setup-homebrew@master is deprecated. Please update your workflow references to use Homebrew/actions/setup-homebrew@main. The "master" branch sync will stop and this warning will become an error when Homebrew 5.2.0 is released (no earlier than 2026-06-10).
test (20.x)
Node.js 20 actions are deprecated. The following actions are running on Node.js 20 and may not work as expected: actions/checkout@v4. Actions will be forced to run with Node.js 24 by default starting June 2nd, 2026. Node.js 20 will be removed from the runner on September 16th, 2026. Please check if updated versions of these actions are available that support Node.js 24. To opt into Node.js 24 now, set the FORCE_JAVASCRIPT_ACTIONS_TO_NODE24=true environment variable on the runner or in your workflow file. Once Node.js 24 becomes the default, you can temporarily opt out by setting ACTIONS_ALLOW_USE_UNSECURE_NODE_VERSION=true. For more information see: https://github.blog/changelog/2025-09-19-deprecation-of-node-20-on-github-actions-runners/
test (20.x)
Homebrew/actions/setup-homebrew@master is deprecated. Please update your workflow references to use Homebrew/actions/setup-homebrew@main. The "master" branch sync will stop and this warning will become an error when Homebrew 5.2.0 is released (no earlier than 2026-06-10).