cloudamqp
diff --git a/‎.gitignore‎
Lines changed: 1 addition & 0 deletions b/‎.gitignore‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎amqpclient.mjs‎
Lines changed: 9 additions & 4 deletions b/‎amqpclient.mjs‎
Lines changed: 9 additions & 4 deletions
@@ -1,3 +1,4 @@
+premaster.txt
 package-lock.json
 # Logs
 logs
 
@@ -1,5 +1,6 @@
-import AMQPBaseClient from './amqpclient-base.mjs'
-import AMQPView from './amqpview.mjs'
+import AMQPBaseClient from './lib/amqpclient-base.mjs'
+import AMQPError from './lib/amqp-error.mjs'
+import AMQPView from './lib/amqp-view.mjs'
 import { Buffer } from 'buffer'
 import net from 'net'
 import tls from 'tls'
@@ -18,11 +19,15 @@ export default class AMQPClient extends AMQPBaseClient {
   }
 
   connect() {
-    this.socket = this.tls ? this.connectTLS() : this.connectPlain()
+    const socket = this.tls ? this.connectTLS() : this.connectPlain()
+    Object.defineProperty(this, 'socket', {
+      value: socket,
+      enumerable: false // hide it from console.log etc.
+    })
     return new Promise((resolve, reject) => {
       this.resolvePromise = resolve
       this.rejectPromise = reject
-      this.socket.on('error', reject)
+      this.socket.on('error', (err) => reject(new AMQPError(err, this)))
     })
   }
Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,4 @@`
	`1`	`+premaster.txt`
`1`	`2`	`package-lock.json`
`2`	`3`	`# Logs`
`3`	`4`	`logs`