Skip to content

Commit 92a83bb

Browse files
committed
increase wait timeout for slow CIs
1 parent 38f1e1e commit 92a83bb

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/amqp-websocket-client.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ export default class AMQPWebSocketClient extends AMQPBaseClient {
1111
private frameSize = 0
1212
private frameBuffer: Uint8Array
1313

14-
/**
14+
/**
1515
* @param url to the websocket endpoint, example: wss://server/ws/amqp
1616
*/
1717
constructor(url: string, vhost = "/", username = "guest", password = "guest", name?: string, frameMax = 4096, heartbeat = 0) {

test/test.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ test('will clear consumer wait timeout on cancel', async t => {
153153
const ch = await conn.channel()
154154
const q = await ch.queue("")
155155
const consumer = await q.subscribe({noAck: false}, () => "")
156-
const wait = consumer.wait(1000);
156+
const wait = consumer.wait(5000);
157157
consumer.cancel()
158158
const ok = await wait
159159
t.is(ok, undefined)
@@ -236,7 +236,7 @@ test('wait for publish confirms', async t => {
236236
t.deepEqual(tags, [3,4])
237237
})
238238

239-
test('can handle rejects', async t => {
239+
test('can handle returned messages', async t => {
240240
const amqp = new AMQPClient("amqp://127.0.0.1")
241241
const conn = await amqp.connect()
242242
const ch = await conn.channel()

0 commit comments

Comments
 (0)