message: expose delivering nsqd address as string

nsqio · Dec 23, 2014 · da9a41a · da9a41a
1 parent 4e74fa1
commit da9a41a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/conn.go b/conn.go
@@ -496,6 +496,7 @@ func (c *Conn) readLoop() {
 				goto exit
 			}
 			msg.Delegate = delegate
+			msg.NSQDAddress = c.String()
 
 			atomic.AddInt64(&c.rdyCount, -1)
 			atomic.AddInt64(&c.messagesInFlight, 1)

diff --git a/message.go b/message.go
@@ -23,6 +23,8 @@ type Message struct {
 	Timestamp int64
 	Attempts  uint16
 
+	NSQDAddress string
+
 	Delegate MessageDelegate
 
 	autoResponseDisabled int32