mahmoud · January 5, 2018 00:03
diff --git a/postgres_queue_get.sql b/postgres_queue_get.sql
 DELETE FROM {table_name}
 WHERE id = (
    SELECT id
    FROM {0}
    WHERE deliver_after <= now()
        AND q_name IN (SELECT unnest({q_names}))
    ORDER BY priority DESC, created_at
    FOR UPDATE SKIP LOCKED
    LIMIT 1
 )
 RETURNING *;
	DELETE FROM {table_name}
	WHERE id = (
	SELECT id
	FROM {0}
	WHERE deliver_after <= now()
	AND q_name IN (SELECT unnest({q_names}))
	ORDER BY priority DESC, created_at
	FOR UPDATE SKIP LOCKED
	LIMIT 1
	)
	RETURNING *;