Merge pull request #8 from charlie67/main

Allow ContentType field of publish command to be specified
grafana · Jun 30, 2022 · 6cefe10 · 6cefe10
2 parents 2e91cc3 + e515b3b
commit 6cefe10
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 3 deletions.
diff --git a/README.md b/README.md
@@ -70,7 +70,8 @@ export default function () {
 
   Amqp.publish({
     queue_name: queueName,
-    body: "Ping from k6"
+    body: "Ping from k6",
+    content_type: "text/plain"
     // exchange: '',
     // mandatory: false,
     // immediate: false,

diff --git a/amqp.go b/amqp.go
@@ -22,6 +22,7 @@ type PublishOptions struct {
 	QueueName string
 	Body      string
 	Exchange  string
+	ContentType string
 	Mandatory bool
 	Immediate bool
 }
@@ -69,7 +70,7 @@ func (amqp *Amqp) Publish(options PublishOptions) error {
 		options.Mandatory,
 		options.Immediate,
 		amqpDriver.Publishing{
-			ContentType: "text/plain",
+			ContentType: options.ContentType,
 			Body:        []byte(options.Body),
 		},
 	)

diff --git a/build.sh b/build.sh
diff --git a/examples/publish-listen.js b/examples/publish-listen.js
@@ -27,6 +27,7 @@ export default function () {
       exchange: '',
       mandatory: false,
       immediate: false,
+      content_type: "text/plain",
       body: "Ping from k6 -> " + mark
     })
   }

diff --git a/examples/test.js b/examples/test.js
@@ -24,7 +24,8 @@ export default function () {
 
   Amqp.publish({
     queue_name: queueName,
-    body: "Ping from k6"
+    body: "Ping from k6",
+    content_type: "text/plain"
     // exchange: '',
     // mandatory: false,
     // immediate: false,