feat(pass-nessage-subject-as-header): removed redundant subject field…

… in Options Struct
roadrunner-server · Dec 1, 2023 · 18b42f9 · 18b42f9
1 parent 266e409
commit 18b42f9
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 3 deletions.
diff --git a/natsjobs/item.go b/natsjobs/item.go
@@ -46,7 +46,6 @@ type Options struct {
 	stream         string
 	seq            uint64
 	sub            jetstream.Stream
-	subject        string
 }
 
 // DelayDuration returns delay duration in a form of time.Duration.

diff --git a/natsjobs/listener.go b/natsjobs/listener.go
@@ -94,8 +94,6 @@ func (c *Driver) listenerStart() { //nolint:gocognit
 				item.Options.requeueFn = c.requeue
 				// sequence needed for the requeue
 				item.Options.seq = meta.Sequence.Stream
-				// subject needed to pass it as header
-				item.Options.subject = m.Subject()
 
 				// needed only if delete after ack is true
 				if c.deleteAfterAck {