bug fix

logger.go

@@ -22,22 +22,17 @@ type Logger interface {
 
 type logger struct{}
 
-func (l *logger) Trace(args ...interface{})
-func (l *logger) Tracef(format string, args ...interface{})
-
-func (l *logger) Debug(args ...interface{})
-func (l *logger) Debugf(format string, args ...interface{})
-
-func (l *logger) Info(args ...interface{})
-func (l *logger) Infof(format string, args ...interface{})
-
-func (l *logger) Error(args ...interface{})
-func (l *logger) Errorf(format string, args ...interface{})
-
-func (l *logger) Fatal(args ...interface{})
-func (l *logger) Fatalf(format string, args ...interface{})
-
-func (l *logger) Panic(args ...interface{})
-func (l *logger) Panicf(format string, args ...interface{})
+func (l *logger) Trace(args ...interface{})                 {}
+func (l *logger) Tracef(format string, args ...interface{}) {}
+func (l *logger) Debug(args ...interface{})                 {}
+func (l *logger) Debugf(format string, args ...interface{}) {}
+func (l *logger) Info(args ...interface{})                  {}
+func (l *logger) Infof(format string, args ...interface{})  {}
+func (l *logger) Error(args ...interface{})                 {}
+func (l *logger) Errorf(format string, args ...interface{}) {}
+func (l *logger) Fatal(args ...interface{})                 {}
+func (l *logger) Fatalf(format string, args ...interface{}) {}
+func (l *logger) Panic(args ...interface{})                 {}
+func (l *logger) Panicf(format string, args ...interface{}) {}
 
 var DefaultLogger = &logger{}

manager.go

@@ -47,9 +47,11 @@ func (m *Manager) Run() {
 			m.Connections[connection.ID] = connection
 			m.logger.Tracef("connection '%s' registered", connection.ID)
 		case connection := <-m.delConnection:
-			connection.Close()
-			delete(m.Connections, connection.ID)
-			m.logger.Tracef("connection '%s' unregistered", connection.ID)
+			if !connection.closed {
+				connection.Close()
+				delete(m.Connections, connection.ID)
+				m.logger.Tracef("connection '%s' unregistered", connection.ID)
+			}
 		case onReceiveQueue <- true:
 			go m.onReceive(onReceiveQueue)
 		}