diff --git a/streaming/index.js b/streaming/index.js
index 9db23b876..ebdfd1e09 100644
--- a/streaming/index.js
+++ b/streaming/index.js
@@ -822,8 +822,8 @@ const startServer = async () => {
             transmit(event, payload);
           }
         }).catch(err => {
-          releasePgConnection();
           log.error(err);
+          releasePgConnection();
         });
       });
     };