diff --git a/src/classes/queue.ts b/src/classes/queue.ts index 078b854..7f43b83 100644 --- a/src/classes/queue.ts +++ b/src/classes/queue.ts @@ -15,6 +15,7 @@ export class Queue { const query = readQuery(this.name, vt) const conn = await this.pool.connect() const result = await conn.query(query) + conn.release() return parseDbMessage(result.rows[0]) }