diff --git a/core/core.go b/core/core.go index d6ec896..096b472 100644 --- a/core/core.go +++ b/core/core.go @@ -52,7 +52,7 @@ func (a *Account) Receive() { panic("channel closed") } - log.Info("pushing message") + log.Infoln("pushing message") a.Push(m) } } diff --git a/server/server.go b/server/server.go index b13e768..8a76ed4 100644 --- a/server/server.go +++ b/server/server.go @@ -46,7 +46,7 @@ func (svc *Service) QueueMessage(ctx context.Context, msg *pb.Message) (*pb.Resp qmsg := core.NewMessage(msg) if qmsg == nil { - log.Err("server: invalid message received, dropping") + log.Errln("server: invalid message received, dropping") return &pb.Response{ Timestamp: time.Now().Unix(), Id: uuid.NewString(),