mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-04-08 09:54:33 +00:00
Code Activity

adjusted gob error output

Browse source
This commit is contained in:
postmannen 2022-02-16 12:50:45 +01:00
parent a26f596169
commit b36cb08277
1 changed files with 2 additions and 2 deletions

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: subject=%v,lenght nats msgData=%v, error=%v", subject, len(msgData), 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: subject=%v,lenght nats msgData=%v, error=%v", subject, len(msgData), 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