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(),