From 219d8e8c810b761aaa110578299a106fde389890 Mon Sep 17 00:00:00 2001 From: Kyle Isom Date: Fri, 9 Jun 2023 16:46:46 -0700 Subject: [PATCH] add more logging --- core/core.go | 1 + server/server.go | 1 + 2 files changed, 2 insertions(+) diff --git a/core/core.go b/core/core.go index 8ff9304..d6ec896 100644 --- a/core/core.go +++ b/core/core.go @@ -52,6 +52,7 @@ func (a *Account) Receive() { panic("channel closed") } + log.Info("pushing message") a.Push(m) } } diff --git a/server/server.go b/server/server.go index 1728096..b13e768 100644 --- a/server/server.go +++ b/server/server.go @@ -35,6 +35,7 @@ func (svc *Service) QueueMessage(ctx context.Context, msg *pb.Message) (*pb.Resp if stream == "" { acct = svc.Default } else if acct, ok = svc.Accounts[stream]; !ok { + log.Errf("invalid stream name '%s' in message", stream) return &pb.Response{ Timestamp: time.Now().Unix(), Id: uuid.NewString(),