mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-31 01:24:31 +00:00
Code Activity

changed error output

Browse source
This commit is contained in:
postmannen 2022-02-16 13:09:55 +01:00
parent b36cb08277
commit 9e9a48ee35
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
process.go
View file

@ -415,7 +415,7 @@ func (p process) messageSubscriberHandler(natsConn *nats.Conn, thisNode string,
err := gobDec.Decode(&message)
if err != nil {
er := fmt.Errorf("error: gob decoding failed serial header: subject=%v,header=%v, error=%v", subject, msg.Header, err)
er := fmt.Errorf("error: gob decoding failed serial header, subject: %v, header: %v, error: %v", subject, msg.Header, err)
p.processes.errorKernel.errSend(p, message, er)
return
}
@ -428,7 +428,7 @@ func (p process) messageSubscriberHandler(natsConn *nats.Conn, thisNode string,
err := gobDec.Decode(&message)
if err != nil {
er := fmt.Errorf("error: gob decoding failed no-serial header: subject=%v,header=%v, error=%v", subject, msg.Header, err)
er := fmt.Errorf("error: gob decoding failed no-serial header, subject: %v, header: %v, error: %v", subject, msg.Header, err)
log.Printf("%v\n", er)
p.processes.errorKernel.errSend(p, message, er)
return