diff --git a/cmd/echo/main.go b/cmd/echo/main.go
index 71c716d..ea566a4 100644
--- a/cmd/echo/main.go
+++ b/cmd/echo/main.go
@@ -8,7 +8,6 @@ import (
 	"net"
 	"os"
 
-	"github.com/ThreeDotsLabs/watermill"
 	"github.com/ThreeDotsLabs/watermill/message"
 	"github.com/ThreeDotsLabs/watermill/message/router/middleware"
 	"github.com/ThreeDotsLabs/watermill/message/router/plugin"
@@ -34,7 +33,6 @@ func main() {
 		log.Fatalf("error binding to port %d\n: %s", port, err)
 	}
 	defer l.Close()
-	wmLogger := watermill.NewStdLogger(false, false)
 
 	traceFile, err := os.OpenFile("trace.log", os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0644)
 	if err != nil {
@@ -67,7 +65,7 @@ func main() {
 		middleware.Recoverer,
 	)
 
-	pubSub := gochannel.NewGoChannel(gochannel.Config{}, wmLogger)
+	pubSub := gochannel.NewGoChannel(gochannel.Config{}, wrappedSlogger)
 
 	ctx := context.Background()
 	ts := telnet.NewTELNETServer(ctx, l, pubSub, wrappedSlogger)