From 7b4428c51067e7d77998f636ea2657911529da10 Mon Sep 17 00:00:00 2001 From: jochen Date: Thu, 8 Oct 2026 16:32:19 +0200 Subject: [PATCH] Name the worker a piece of work came from, so a bundle taking two is handed each to its own handler --- node-tools/internal/bus/seat.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/node-tools/internal/bus/seat.go b/node-tools/internal/bus/seat.go index 7d6704f..5eafb12 100644 --- a/node-tools/internal/bus/seat.go +++ b/node-tools/internal/bus/seat.go @@ -195,6 +195,7 @@ func (c *Conn) SeatAnswer(module, subject string, answer func(subject string, bo // Work is one message a holder took from a seat's work queue. type Work struct { + Worker string `json:"worker"` Subject string `json:"subject"` Body json.RawMessage `json:"body"` Headers map[string]string `json:"headers,omitempty"` @@ -241,7 +242,7 @@ func (c *Conn) SeatTake(module, consumer string, deliver func(Work) error) (func for k := range msg.Headers() { headers[k] = msg.Headers().Get(k) } - if err := deliver(Work{Subject: msg.Subject(), Body: json.RawMessage(msg.Data()), Headers: headers}); err != nil { + if err := deliver(Work{Worker: w.Consumer, Subject: msg.Subject(), Body: json.RawMessage(msg.Data()), Headers: headers}); err != nil { _ = msg.NakWithDelay(NakDelay) return }