3.3.0 #22
baelterAnnotations
10 errors
|
test/test.ts > will throw an error after consumer timeout:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 32, 59, 192, 97, 134, 127, +0, +0, 128, 121, 220, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 109, 113, 112, 5, 1, +0, +0, 176, 236, 208, 22, +0, +0, +0, +0, 80, 90, 209, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 222, 98, 151, 133, 1, +0, +0, +0, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, +0, +0, +0, +0, 184, 236, 208, 22, +0, +0, +0, +0, 120, 90, 209, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, +0, +0, +0, 99, 111, 110, 110, +0, +0, +0, +0, 192, 236, 208, 22, +0, +0, +0, +0, 168, 90, 209, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 2, 112, 200, 170, 1, 127, +0, +0, 99, 111, 110, 110, 101, 99, 116, +0, 200, 236, 208, 22, +0, +0, +0, +0, 208, 90, 209, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 58, 244, 111, 19, 1, +0, +0, +0, 99, 104, 217, 22, +0, +0, +0, +0, 208, 236, 208, 22, +0, +0, +0, +0, 248, 90, 209, 22, +0, +0, +0, +0, 2, +0, +0, +0, +0, +0, +0, +0, 198, 236, 42, 179, 1, 27, +0, +0, 99, 104, 97, 110, 110, 101, 108, +0, 216, 236, 208, 22, +0, +0, +0, +0, 32, 91, 209, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 26, 101, 193, 249, 1, +0, +0, +0, 113, 91, 209, 22, +0, +0, +0, +0, 224, 236, 208, 22, +0, +0, +0, +0, 72, 91, 209, 22, +0, +0, +0, +0, 1, +0, +0, +0, +0, +0, +0, +0, 186, 120, 220, 225, 1, +0, +0, +0, 113, 117, 101, 117, 101, 127, +0, +0, 232, 236, 208, 22, +0, +0, +0, +0, 112, 91, 209, 22, +0, +0, +0, +0, 5, +0, +0, +0, +0, +0, +0, +0, 214, 97, 190, 224,
|
|
test/test.ts > will throw an error:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 32, 66, 192, 97, 134, 127, +0, +0, 224, 149, 224, 22, +0, +0, +0, +0, 224, 149, 224, 22, +0, +0, +0, +0, 224, 149, 224, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 109, 113, 112, +0, +0, +0, +0, 176, 236, 208, 22, +0, +0, +0, +0, 16, 19, 220, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 222, 98, 151, 133, 1, +0, +0, +0, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, 55, +0, +0, +0, 184, 236, 208, 22, +0, +0, +0, +0, 56, 19, 220, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, 127, +0, +0, 99, 111, 110, 110, +0, +0, +0, +0, 192, 236, 208, 22, +0, +0, +0, +0, 104, 19, 220, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 2, 112, 200, 170, 1, +0, +0, +0, 99, 111, 110, 110, 101, 99, 116, +0, 200, 236, 208, 22, +0, +0, +0, +0, 144, 19, 220, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 58, 244, 111, 19, 1, 255, 255, 255, 99, 104, +0, +0, 2, +0, +0, +0, 208, 236, 208, 22, +0, +0, +0, +0, 184, 19, 220, 22, +0, +0, +0, +0, 2, +0, +0, +0, +0, +0, +0, +0, 198, 236, 42, 179, 1, +0, +0, +0, 99, 104, 97, 110, 110, 101, 108, +0, 216, 236, 208, 22, +0, +0, +0, +0, 224, 19, 220, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 26, 101, 193, 249, 1, +0, +0, +0, 95, 95, 118, 105, 116, 101, 95, 115, 115, 114, 95, 105, 109, 112, 111, 114, 116, 95, 48, 95, 95, +0, +0, +0, 224, 236, 208, 22, +0, +0, +0, +0, 8, 20, 220, 22, +0, +0, +0, +0, 21, +0, +0, +0, +0, +0, +0, +0, 46, 250, 84, 186, 1, +0, +0, +0, 101, 120, 112, 101, 99, 116, +0, +0, 232, 236, 208, 22, +0, +0, +0, +0, 64,
|
|
test/test.ts > can get message from a queue:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 16, 66, 192, 97, 134, 127, +0, +0, 16, 66, 192, 97, 134, 127, +0, +0, 240, 21, 224, 22, +0, +0, +0, +0, 240, 21, 224, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 109, 113, 112, +0, +0, +0, +0, 176, 236, 208, 22, +0, +0, +0, +0, 48, 22, 224, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 222, 98, 151, 133, 1, +0, +0, +0, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, +0, +0, +0, +0, 184, 236, 208, 22, +0, +0, +0, +0, 88, 22, 224, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, +0, +0, +0, 99, 111, 110, 110, +0, +0, +0, +0, 192, 236, 208, 22, +0, +0, +0, +0, 136, 22, 224, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 2, 112, 200, 170, 1, 11, +0, +0, 99, 111, 110, 110, 101, 99, 116, +0, 200, 236, 208, 22, +0, +0, +0, +0, 176, 22, 224, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 58, 244, 111, 19, 1, +0, +0, +0, 99, 104, +0, +0, +0, +0, +0, +0, 208, 236, 208, 22, +0, +0, +0, +0, 216, 22, 224, 22, +0, +0, +0, +0, 2, +0, +0, +0, +0, +0, +0, +0, 198, 236, 42, 179, 1, +0, +0, +0, 99, 104, 97, 110, 110, 101, 108, +0, 216, 236, 208, 22, +0, +0, +0, +0, +0, 23, 224, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 26, 101, 193, 249, 1, +0, +0, +0, 113, +0, +0, +0, +0, +0, +0, +0, 224, 236, 208, 22, +0, +0, +0, +0, 40, 23, 224, 22, +0, +0, +0, +0, 1, +0, +0, +0, +0, +0, +0, +0, 186, 120, 220, 225, 1, +0, +0, +0, 113, 117, 101, 117, 101, +0, +0, +0, 232, 236, 208, 22, +0, +0, +0, +0, 80, 23, 224, 22, +0, +0, +0, +0, 5, +0, +0, +0, +0, +0, +0, +0, 214, 97, 190, 224,
|
|
test/test.ts > can delete a queue:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 16, 66, 192, 97, 134, 127, +0, +0, 16, 66, 192, 97, 134, 127, +0, +0, 224, 245, 223, 22, +0, +0, +0, +0, 224, 245, 223, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 109, 113, 112, +0, +0, +0, +0, 176, 236, 208, 22, +0, +0, +0, +0, 32, 246, 223, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 222, 98, 151, 133, 1, +0, +0, +0, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, 55, +0, +0, +0, 184, 236, 208, 22, +0, +0, +0, +0, 72, 246, 223, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, 127, +0, +0, 99, 111, 110, 110, +0, +0, +0, +0, 192, 236, 208, 22, +0, +0, +0, +0, 120, 246, 223, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 2, 112, 200, 170, 1, +0, +0, +0, 99, 111, 110, 110, 101, 99, 116, +0, 200, 236, 208, 22, +0, +0, +0, +0, 160, 246, 223, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 58, 244, 111, 19, 1, 255, 255, 255, 99, 104, +0, +0, 2, +0, +0, +0, 208, 236, 208, 22, +0, +0, +0, +0, 200, 246, 223, 22, +0, +0, +0, +0, 2, +0, +0, +0, +0, +0, +0, +0, 198, 236, 42, 179, 1, +0, +0, +0, 99, 104, 97, 110, 110, 101, 108, +0, 216, 236, 208, 22, +0, +0, +0, +0, 240, 246, 223, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 26, 101, 193, 249, 1, +0, +0, +0, 113, +0, +0, +0, +0, +0, +0, +0, 224, 236, 208, 22, +0, +0, +0, +0, 24, 247, 223, 22, +0, +0, +0, +0, 1, +0, +0, +0, +0, +0, +0, +0, 186, 120, 220, 225, 1, +0, +0, +0, 113, 117, 101, 117, 101, 194, 70, 35, 232, 236, 208, 22, +0, +0, +0, +0, 64, 247, 223, 22, +0, +0, +0, +0, 5, +0, +0, +0, +0, +0, +0, +0, 214,
|
|
test/test.ts > can unsubscribe from a queue:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 16, 66, 192, 97, 134, 127, +0, +0, 224, 245, 223, 22, +0, +0, +0, +0, 224, 245, 223, 22, +0, +0, +0, +0, 224, 245, 223, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 109, 113, 112, +0, +0, +0, +0, 176, 236, 208, 22, +0, +0, +0, +0, 16, 249, 221, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 222, 98, 151, 133, 1, +0, +0, +0, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, 55, +0, +0, +0, 184, 236, 208, 22, +0, +0, +0, +0, 56, 249, 221, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, 127, +0, +0, 99, 111, 110, 110, +0, +0, +0, +0, 192, 236, 208, 22, +0, +0, +0, +0, 104, 249, 221, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 2, 112, 200, 170, 1, +0, +0, +0, 99, 111, 110, 110, 101, 99, 116, +0, 200, 236, 208, 22, +0, +0, +0, +0, 144, 249, 221, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 58, 244, 111, 19, 1, 255, 255, 255, 99, 104, +0, +0, 2, +0, +0, +0, 208, 236, 208, 22, +0, +0, +0, +0, 184, 249, 221, 22, +0, +0, +0, +0, 2, +0, +0, +0, +0, +0, +0, +0, 198, 236, 42, 179, 1, +0, +0, +0, 99, 104, 97, 110, 110, 101, 108, +0, 216, 236, 208, 22, +0, +0, +0, +0, 224, 249, 221, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 26, 101, 193, 249, 1, +0, +0, +0, 113, +0, +0, +0, +0, +0, +0, +0, 224, 236, 208, 22, +0, +0, +0, +0, 8, 250, 221, 22, +0, +0, +0, +0, 1, +0, +0, +0, +0, +0, +0, +0, 186, 120, 220, 225, 1, 127, +0, +0, 113, 117, 101, 117, 101, 127, +0, +0, 232, 236, 208, 22, +0, +0, +0, +0, 48, 250, 221, 22, +0, +0, +0, +0, 5, +0, +0, +0, +0, +0, +0, +0, 214,
|
|
test/test.ts > can unbind a queue from exchange:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 208, 65, 192, 97, 134, 127, +0, +0, 208, 65, 192, 97, 134, 127, +0, +0, 144, 117, 219, 22, +0, +0, +0, +0, 144, 117, 219, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 109, 113, 112, 114, 116, 32, 123, 176, 236, 208, 22, +0, +0, +0, +0, 208, 117, 219, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 222, 98, 151, 133, 1, 109, 111, 100, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, 32, 123, 32, 102, 184, 236, 208, 22, +0, +0, +0, +0, 248, 117, 219, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, 32, 102, 114, 99, 111, 110, 110, 110, 111, 100, 101, 192, 236, 208, 22, +0, +0, +0, +0, 40, 118, 219, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 2, 112, 200, 170, 1, 44, 32, 100, 99, 111, 110, 110, 101, 99, 116, 125, 200, 236, 208, 22, +0, +0, +0, +0, 80, 118, 219, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 58, 244, 111, 19, 1, 119, 115, 32, 99, 104, 112, 114, 111, 99, 101, 115, 208, 236, 208, 22, +0, +0, +0, +0, 120, 118, 219, 22, +0, +0, +0, +0, 2, +0, +0, +0, +0, +0, +0, +0, 198, 236, 42, 179, 1, 32, 100, 114, 99, 104, 97, 110, 110, 101, 108, 115, 216, 236, 208, 22, +0, +0, +0, +0, 160, 118, 219, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 26, 101, 193, 249, 1, 110, 117, 108, 113, 59, 10, 99, 111, 110, 115, 116, 224, 236, 208, 22, +0, +0, +0, +0, 200, 118, 219, 22, +0, +0, +0, +0, 1, +0, +0, +0, +0, +0, +0, +0, 186, 120, 220, 225, 1, 101, 32, 61, 113, 117, 101, 117, 101, 105, 118, 101, 232, 236, 208, 22, +0, +0, +0, +0, 240, 118, 219, 22, +0, +0, +0, +0
|
|
test/test.ts > can reject a message:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 32, 59, 192, 97, 134, 127, +0, +0, 32, 59, 192, 97, 134, 127, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 109, 113, 112, +0, +0, +0, +0, 176, 236, 208, 22, +0, +0, +0, +0, 80, 134, 221, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 222, 98, 151, 133, 1, 27, +0, +0, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, 128, 27, +0, +0, 184, 236, 208, 22, +0, +0, +0, +0, 120, 134, 221, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, 27, +0, +0, 80, 114, 111, 109, 105, 115, 101, +0, 192, 236, 208, 22, +0, +0, +0, +0, 168, 134, 221, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 14, 15, 208, 209, 1, 27, +0, +0, 114, 101, 115, 111, 108, 118, 101, +0, 200, 236, 208, 22, +0, +0, +0, +0, 208, 134, 221, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 234, 22, 148, 82, 1, 27, +0, +0, 114, 101, 106, 101, 99, 116, +0, +0, 208, 236, 208, 22, +0, +0, +0, +0, 248, 134, 221, 22, +0, +0, +0, +0, 6, +0, +0, +0, +0, +0, +0, +0, 158, 58, 86, 178, 1, +0, +0, +0, 99, 111, 110, 110, 101, 99, 116, +0, 216, 236, 208, 22, +0, +0, +0, +0, 32, 135, 221, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 58, 244, 111, 19, 1, +0, +0, +0, 116, 104, 101, 110, +0, +0, +0, +0, 224, 236, 208, 22, +0, +0, +0, +0, 72, 135, 221, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 82, 31, 89, 215, 1, +0, +0, +0, 99, 111, 110, 110, +0, +0, +0, +0, 232, 236, 208, 22, +0, +0, +0, +0, 112, 135, 221, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 2, 112,
|
|
test/test.ts > can nack a message:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 232, 149, 18, 26, 252, 127, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 8, 32, +0, +0, +0, +0, +0, +0, 104, 229, 203, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 109, 113, 112, +0, +0, +0, +0, 176, 236, 208, 22, +0, +0, +0, +0, 64, 70, 226, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 222, 98, 151, 133, 1, +0, +0, +0, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, +0, +0, +0, +0, 184, 236, 208, 22, +0, +0, +0, +0, 104, 70, 226, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, +0, +0, +0, 80, 114, 111, 109, 105, 115, 101, +0, 192, 236, 208, 22, +0, +0, +0, +0, 152, 70, 226, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 14, 15, 208, 209, 1, +0, +0, +0, 114, 101, 115, 111, 108, 118, 101, +0, 200, 236, 208, 22, +0, +0, +0, +0, 192, 70, 226, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 234, 22, 148, 82, 1, +0, +0, +0, 114, 101, 106, 101, 99, 116, +0, +0, 208, 236, 208, 22, +0, +0, +0, +0, 232, 70, 226, 22, +0, +0, +0, +0, 6, +0, +0, +0, +0, +0, +0, +0, 158, 58, 86, 178, 1, +0, +0, +0, 99, 111, 110, 110, 101, 99, 116, +0, 216, 236, 208, 22, +0, +0, +0, +0, 16, 71, 226, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 58, 244, 111, 19, 1, +0, +0, +0, 116, 104, 101, 110, +0, +0, +0, +0, 224, 236, 208, 22, +0, +0, +0, +0, 56, 71, 226, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 82, 31, 89, 215, 1, +0, +0, +0, 99, 111, 110, 110, +0, +0, +0, +0, 232, 236, 208, 22, +0, +0, +0, +0, 96, 71, 226, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 2, 112, 200, 170,
|
|
test/test.ts > can publish and consume:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 32, 59, 192, 97, 134, 127, +0, +0, 240, 81, 222, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 4, +0, 28, 254, 18, 16, +0, +0, 49, 120, 28, 254, 18, 16, +0, +0, 241, 109, 180, 207, 157, 18, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 23, +0, +0, +0, +0, +0, +0, +0, 190, 7, 100, 242, 1, 101, 95, 115, +0, 101, 116, 116, 101, 114, 95, 115, 224, 247, 224, 22, +0, +0, +0, +0, 1, +0, +0, +0, 195, 3, 116, 52, 1, +0, +0, +0, +0, +0, +0, +0, 128, 248, 224, 22, +0, +0, +0, +0, 3, +0, +0, +0, 212, 71, 214, 53, 1, 236, 208, 22, +0, +0, +0, +0, 224, 146, 222, 22, +0, +0, +0, +0, 6, +0, +0, +0, +0, +0, +0, +0, +0, 159, 50, 54, 1, 112, 111, 114, 100, 101, 102, 105, 110, 101, 80, 114, 111, 112, 101, 114, 116, 121, +0, +0, +0, 236, 208, 22, +0, +0, +0, +0, 8, 147, 222, 22, +0, +0, +0, +0, 14, +0, +0, +0, +0, +0, +0, +0, +0, 137, 211, 142, 1, 101, 95, 115, 101, 120, 112, 111, 114, 116, 115, 114, 232, 236, 208, 22, +0, +0, +0, +0, +0, 147, 222, 22, +0, +0, +0, +0, 7, +0, +0, +0, +0, +0, +0, +0, 214, 13, 55, 177, 1, +0, +0, +0, +0, 110, 117, 109, 101, 114, 97, 98, 144, 85, 222, 22, +0, +0, +0, +0, +0, +0, +0, +0, 250, 253, 251, 92, 1, 147, 222, 22, +0, +0, +0, +0, 10, +0, +0, +0, +0, +0, +0, +0, 34, 61, 234, 59, 1, +0, +0, +0, +0, 111, 110, 102, 105, 103, 117, 114, 97, 98, 108, 101, 1, 101, 95, 115, 248, 236, 208, 22, +0, +0, +0, +0, +0, 147, 222, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 190, 162, 117, 223, 1, +0, +0, +0, +0, 147
|
|
test/test.ts > can open a connection and a channel:
src/amqp-socket-client.ts#L81
AMQPError: connect ECONNREFUSED 127.0.0.1:5672
❯ Socket.<anonymous> src/amqp-socket-client.ts:81:42
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { connection: { closed: true, channelMax: +0, textEncoder: { constructor: 'Function<TextEncoder>', encoding: 'utf-8', encode: 'Function<encode>', encodeInto: 'Function<encodeInto>' }, bufferPool: [], vhost: '/', username: 'guest', password: 'guest', platform: 'node v20.19.5 linux x64', logger: undefined, 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>', logger: undefined, open: 'Function<open>', queue: 'Function<queue>', 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, tls: false, tlsOptions: undefined, host: '127.0.0.1', port: 5672, insecure: false, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 64, 66, 192, 97, 134, 127, +0, +0, 64, 66, 192, 97, 134, 127, +0, +0, 224, 149, 224, 22, +0, +0, +0, +0, 224, 149, 224, 22, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 103, 101, 116, 78, 101, 119, 67, 108, 105, 101, 110, 116, +0, +0, +0, +0, 192, 236, 208, 22, +0, +0, +0, +0, 32, 150, 224, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 86, 128, 175, 56, 1, 119, 67, 108, 105, 110, 105, 116, +0, +0, +0, +0, 200, 236, 208, 22, +0, +0, +0, +0, 80, 150, 224, 22, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 138, 89, 52, 105, 1, 79, 102, +0, 117, 114, 108, 110, 101, 99, 116, +0, 208, 236, 208, 22, +0, +0, +0, +0, 120, 150, 224, 22, +0, +0, +0, +0, 3, +0, +0, +0, +0, +0, +0, +0, 230, 133, 89, 184, 1, 116, +0, +0, 85, 82, 76, 110, +0, +0, +0, +0, 216, 236, 208, 22, +0, +0, +0, +0, 160, 150, 224, 22, +0, +0, +0, +0, 3, +0, +0, +0, +0, +0, +0, +0, 234, 243, 68, 255, 1, +0, +0, +0, 97, 109, 113, 112, 58, 47, 47, 49, 50, 55, 46, 48, 46, 48, 46, 49, 224, 236, 208, 22, +0, +0, +0, +0, 200, 150, 224, 22, +0, +0, +0, +0, 16, +0, +0, +0, +0, +0, +0, +0, 190, 93, 227, 22, 1, 101, 108, +0, 102, 114, 97, 109, 101, 77, 97, 120, 232, 236, 208, 22, +0, +0, +0, +0, 248, 150, 224, 22, +0, +0, +0, +0, 8, +0, +0, +0, +0, +0, +0, +0, 250, 215, 227, 122, 1, 114, 101, 115, 115, 101, 97, 114, 99, 104, 80, 97, 114, 97, 109, 115, +0, +0, +0, +0, 240, 236, 208, 22, +0, +0, +0, +0, 32, 151, 224, 22, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 66, 82, 224, 173, 1, 112, 111, 114, 97, 112, 112, 101, 110, 100, +0, +0, 248, 236, 208, 22, +0,
|