mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-15 18:58:14 +00:00
Code Activity

added subject to gob decode error output

Browse source
This commit is contained in:
postmannen 2022-02-16 09:30:50 +01:00
parent cbba482371
commit fa7e639223
1 changed files with 4 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
process.go
View file

@ -342,7 +342,7 @@ func (p process) messageDeliverNats(natsMsgPayload []byte, natsMsgHeader nats.He
// the state of the message being processed, and then reply back to the // the state of the message being processed, and then reply back to the
// correct sending process's reply, meaning so we ACK back to the correct // correct sending process's reply, meaning so we ACK back to the correct
// publisher. // publisher.
func (p process) messageSubscriberHandler(natsConn *nats.Conn, thisNode string, msg *nats.Msg) { func (p process) messageSubscriberHandler(natsConn *nats.Conn, thisNode string, msg *nats.Msg, subject string) {
// Variable to hold a copy of the message data, so we don't mess with // Variable to hold a copy of the message data, so we don't mess with
// the original data since the original is a pointer value. // the original data since the original is a pointer value.
@ -415,9 +415,7 @@ func (p process) messageSubscriberHandler(natsConn *nats.Conn, thisNode string,
err := gobDec.Decode(&message) err := gobDec.Decode(&message)
if err != nil { if err != nil {
er := fmt.Errorf("error: gob decoding failed: %v", err) er := fmt.Errorf("error: gob decoding failed: subject=%v,lenght nats msgData=%v, error=%v", subject, len(msgData), err)
log.Printf("%v\n", er)
fmt.Printf(" * DEBUG1: message: %#v\n", message)
p.processes.errorKernel.errSend(p, message, er) p.processes.errorKernel.errSend(p, message, er)
return return
} }
@ -430,9 +428,8 @@ func (p process) messageSubscriberHandler(natsConn *nats.Conn, thisNode string,
err := gobDec.Decode(&message) err := gobDec.Decode(&message)
if err != nil { if err != nil {
er := fmt.Errorf("error: gob decoding failed: %v", err) er := fmt.Errorf("error: gob decoding failed: subject=%v,lenght nats msgData=%v, error=%v", subject, len(msgData), err)
log.Printf("%v\n", er) log.Printf("%v\n", er)
fmt.Printf(" * DEBUG2: message: %#v\n", message)
p.processes.errorKernel.errSend(p, message, er) p.processes.errorKernel.errSend(p, message, er)
return return
} }
@ -554,7 +551,7 @@ func (p process) subscribeMessages() *nats.Subscription {
//_, err := p.natsConn.Subscribe(subject, func(msg *nats.Msg) { //_, err := p.natsConn.Subscribe(subject, func(msg *nats.Msg) {
// Start up the subscriber handler. // Start up the subscriber handler.
go p.messageSubscriberHandler(p.natsConn, p.configuration.NodeName, msg) go p.messageSubscriberHandler(p.natsConn, p.configuration.NodeName, msg, subject)
}) })
if err != nil { if err != nil {
log.Printf("error: Subscribe failed: %v\n", err) log.Printf("error: Subscribe failed: %v\n", err)