diff --git a/extensions/debug.go b/extensions/debug.go index 5041eb1..7dde847 100644 --- a/extensions/debug.go +++ b/extensions/debug.go @@ -8,7 +8,7 @@ import ( ) func debugJson(v interface{}) string { - b, _ := json.MarshalIndent(v, "", " ") + b, _ := json.MarshalIndent(v, "", " ") return string(b) } @@ -20,7 +20,7 @@ type DebugExtension struct { func NewDebugExtension(out io.Writer) *DebugExtension { li := log.New(out, "InMsg", 0) - lo := log.New(out, "outMsg", 0) + lo := log.New(out, "OutMsg", 0) return &DebugExtension{in: li, out: lo} } diff --git a/transport/websocket/websocket.go b/transport/websocket/websocket.go index 271f550..88b5bfa 100644 --- a/transport/websocket/websocket.go +++ b/transport/websocket/websocket.go @@ -315,10 +315,10 @@ func (w *Websocket) Subscribe(channel string) (*subscription.Subscription, error //todo timeout here err := <-subRes if err != nil { - log.Println(err) + //log.Println(err) return nil, err } - log.Println(sub) + //log.Println(sub) return sub, nil }