Running Copilot coding agent #16
Annotations
2 errors
|
test/tls.ts > can batch send message:
src/amqp-socket-client.ts#L81
AMQPError: read ECONNRESET
❯ TLSSocket.<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.6 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: true, tlsOptions: undefined, host: 'localhost', port: 5671, insecure: true, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 176, 66, 64, 157, 246, 127, +0, +0, 176, 66, 64, 157, 246, 127, +0, +0, 128, 234, 251, 53, +0, +0, +0, +0, 128, 234, 251, 53, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 115, 115, 101, 114, 116, 79, 102, 102, 115, 101, 116, 110, 99, +0, +0, 112, 108, 236, 53, +0, +0, +0, +0, 192, 234, 251, 53, +0, +0, +0, +0, 12, +0, +0, +0, +0, +0, +0, +0, 38, 103, 174, 88, 1, 101, 95, 115, 111, 102, 102, 115, 101, 116, 111, 114, 120, 108, 236, 53, +0, +0, +0, +0, 240, 234, 251, 53, +0, +0, +0, +0, 6, +0, +0, +0, +0, +0, +0, +0, 218, 124, 146, 164, 1, +0, +0, +0, 101, 108, 101, 109, 101, 110, 116, 83, 105, 122, 101, 53, +0, +0, +0, +0, 128, 108, 236, 53, +0, +0, +0, +0, 24, 235, 251, 53, +0, +0, +0, +0, 11, +0, +0, +0, +0, +0, +0, +0, 194, 194, 166, 240, 1, 116, 83, 105, 118, 97, 108, 105, 100, 97, 116, 101, 78, 117, 109, 98, 101, 114, +0, +0, 136, 108, 236, 53, +0, +0, +0, +0, 72, 235, 251, 53, +0, +0, +0, +0, 14, +0, +0, +0, +0, +0, +0, +0, 30, 238, 200, 247, 1, 102, 101, 114, 109, 97, 120, 76, 101, 110, 103, 116, 104, 235, 251, 53, +0, +0, +0, +0, 144, 108, 236, 53, +0, +0, +0, +0, 120, 235, 251, 53, +0, +0, +0, +0, 9, +0, +0, +0, +0, +0, +0, +0, 118, 117, 114, 108, 1, 86, 105, 101, 77, 97, 116, 104, 77, 105, 110,
|
|
test/tls.ts > can connect with TLS:
src/amqp-socket-client.ts#L60
AMQPError: Connection ended
❯ TLSSocket.<anonymous> src/amqp-socket-client.ts:60:28
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
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.6 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: true, tlsOptions: undefined, host: '127.0.0.1', port: 5671, insecure: true, framePos: +0, frameSize: +0, frameBuffer: { type: 'Buffer', data: [ 32, 66, 64, 157, 246, 127, +0, +0, 32, 66, 64, 157, 246, 127, +0, +0, 160, 167, 249, 53, +0, +0, +0, +0, 160, 167, 249, 53, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, +0, 97, 108, 108, 111, 99, 97, 116, 101, 112, 108, 236, 53, +0, +0, +0, +0, 224, 167, 249, 53, +0, +0, +0, +0, 8, +0, +0, +0, +0, +0, +0, +0, 2, 83, 148, 27, 1, +0, +0, +0, 115, 105, 122, 101, 1, 101, 120, 116, 120, 108, 236, 53, +0, +0, +0, +0, 8, 168, 249, 53, +0, +0, +0, +0, 4, +0, +0, +0, +0, +0, +0, +0, 42, 158, 145, 69, 1, +0, +0, +0, 70, 97, 115, 116, 66, 117, 102, 102, 101, 114, 108, 105, 100, 97, 116, 101, 128, 108, 236, 53, +0, +0, +0, +0, 48, 168, 249, 53, +0, +0, +0, +0, 10, +0, +0, +0, +0, +0, +0, +0, 146, 255, 109, 24, 1, +0, +0, +0, 66, 117, 102, 102, 101, 114, +0, +0, 136, 108, 236, 53, +0, +0, +0, +0, 96, 168, 249, 53, +0, +0, +0, +0, 6, +0, +0, +0, +0, +0, +0, +0, 234, 252, 103, 16, 1, +0, +0, +0, 112, 111, 111, 108, 83, 105, 122, 101, 144, 108, 236, 53, +0, +0, +0, +0, 136, 168, 249, 53, +0, +0, +0, +0, 8, +0, +0, +0, +0, +0, +0, +0, 118, 200, 135, 113, 1, +0, +0, +0, 112, 111, 111, 108, 79, 102, 102, 115, 101, 116, 148, 27, 1, +0, +0, +0, 152, 108, 236, 53, +0, +0, +0, +0, 176, 168, 249, 53, +0, +0, +0, +0, 10, +0, +0, +0, +
|