|
|
|
@ -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)
|
|
|
|
|