diff --git a/asyncpg/connection.py b/asyncpg/connection.py
index e62928f7..2b21247e 100644
--- a/asyncpg/connection.py
+++ b/asyncpg/connection.py
@@ -1501,16 +1501,7 @@ def _get_reset_query(self):
         if caps.sql_close_all:
             _reset_query.append('CLOSE ALL;')
         if caps.notifications and caps.plpgsql:
-            _reset_query.append('''
-                DO $$
-                BEGIN
-                    PERFORM * FROM pg_listening_channels() LIMIT 1;
-                    IF FOUND THEN
-                        UNLISTEN *;
-                    END IF;
-                END;
-                $$;
-            ''')
+            _reset_query.append('UNLISTEN *;')
         if caps.sql_reset:
             _reset_query.append('RESET ALL;')