Allow ContentType field of publish command to be specified

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,

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),
 		},
 	)

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
     })
   }

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,