diff --git a/src/adapters/web-socket-server-adapter.ts b/src/adapters/web-socket-server-adapter.ts
index 88672ce4..8600272b 100644
--- a/src/adapters/web-socket-server-adapter.ts
+++ b/src/adapters/web-socket-server-adapter.ts
@@ -72,6 +72,9 @@ export class WebSocketServerAdapter extends WebServerAdapter implements IWebSock
         return
       }
       const webSocketAdapter = this.webSocketsAdapters.get(webSocket) as IWebSocketAdapter
+      if (!webSocketAdapter) {
+        return
+      }
       webSocketAdapter.emit(WebSocketAdapterEvent.Event, event)
     })
   }
diff --git a/src/database/client.ts b/src/database/client.ts
index e03b594c..ac2fda8f 100644
--- a/src/database/client.ts
+++ b/src/database/client.ts
@@ -3,6 +3,19 @@ import 'pg-query-stream'
 import knex, { Knex } from 'knex'
 import { createLogger } from '../factories/logger-factory'
 
+knex.Client.prototype.releaseConnection = function (connection) {
+  //debug('releasing connection to pool: %s', connection.__knexUid);
+  console.log('releasing connection to pool')
+  const didRelease = this.pool.release(connection)
+
+  if (!didRelease) {
+    console.log('pool refused connection')
+    //debug('pool refused connection: %s', connection.__knexUid);
+  }
+
+  return Promise.resolve()
+}
+
 const getMasterConfig = (): Knex.Config => ({
   client: 'pg',
   connection: {