Merge pull request #19 from acuderman/feature/enable-queue-publish-he…

…aders Add headers support on queue publish
grafana · Nov 4, 2022 · 4f25f55 · 4f25f55
2 parents 224d7cf + 8f7f43b
commit 4f25f55
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/README.md b/README.md
@@ -68,6 +68,9 @@ export default function () {
     // exchange: '',
     // mandatory: false,
     // immediate: false,
+    // headers: {
+    //   'header-1': '',
+    // },
   })
 
   const listener = function(data) { console.log('received data: ' + data) }

diff --git a/amqp.go b/amqp.go
@@ -25,6 +25,7 @@ type Options struct {
 type PublishOptions struct {
 	QueueName   string
 	Body        string
+	Headers     amqpDriver.Table
 	Exchange    string
 	ContentType string
 	Mandatory   bool
@@ -77,6 +78,7 @@ func (amqp *AMQP) Publish(options PublishOptions) error {
 	}()
 
 	publishing := amqpDriver.Publishing{
+		Headers:     options.Headers,
 		ContentType: options.ContentType,
 		Body:        []byte(options.Body),
 	}