/**
 * Direct PostgreSQL adapter for PGMQ operations
 * Bypasses Supabase JS client to avoid schema cache issues
 */
export declare class PgmqAdapter {
    private pool;
    constructor();
    /**
     * Read a message from the queue
     */
    readMessage(queueName: string, vt: number, qty?: number): Promise<any[]>;
    /**
     * Delete a message from the queue
     */
    deleteMessage(queueName: string, msgId: number): Promise<boolean>;
    /**
     * Send a message to the queue
     */
    sendMessage(queueName: string, message: any): Promise<number>;
    /**
     * Create a queue
     */
    createQueue(queueName: string): Promise<void>;
    /**
     * Close the connection pool
     */
    close(): Promise<void>;
}
//# sourceMappingURL=pgmq.adapter.d.ts.map