diff --git a/src/connection.js b/src/connection.js
index 578a6a02..8f6d8036 100644
--- a/src/connection.js
+++ b/src/connection.js
@@ -385,14 +385,18 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function queryError(query, err) {
-    Object.defineProperties(err, {
-      stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug },
-      query: { value: query.string, enumerable: options.debug },
-      parameters: { value: query.parameters, enumerable: options.debug },
-      args: { value: query.args, enumerable: options.debug },
-      types: { value: query.statement && query.statement.types, enumerable: options.debug }
-    })
-    query.reject(err)
+  if (query instanceof Query) {
+      Object.defineProperties(err, {
+        stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug },
+        query: { value: query.string, enumerable: options.debug },
+        parameters: { value: query.parameters, enumerable: options.debug },
+        args: { value: query.args, enumerable: options.debug },
+        types: { value: query.statement && query.statement.types, enumerable: options.debug }
+      })
+      query.reject(err)
+    } else {
+      console.error(err)
+    }
   }
 
   function end() {