print message properties

Makefile

@@ -1,12 +1,13 @@
 
 
-.PHONY: setup test release
+.PHONY: setup test release rabbit
 
 setup:
 	go get -u github.com/govend/govend
 	go get -u github.com/goreleaser/goreleaser
 	govend
-
+rabbit:
+	docker run --rm -d --name rabbit -p 5672:5672 -p 15672:15672 rabbitmq:3.6.5-management
 # make release tag=v0.0.1
 release:
 	git tag -a $(tag) -m $(tag) && git push origin $(tag) && goreleaser

cmd/consume.go

@@ -2,9 +2,11 @@ package cmd
 
 import (
 	"fmt"
+	"reflect"
 	"strconv"
 	"strings"
 
+	"github.com/oleiade/reflections"
 	"github.com/spf13/cobra"
 	"github.com/streadway/amqp"
 )
@@ -122,8 +124,16 @@ Use comma-separated values for binding the same queue with multiple routing keys
 				fmt.Printf("Queue: %s\n", q.Name)
 				fmt.Printf("Redelivered: %v\n", msg.Redelivered)
 				fmt.Printf("Headers: %v\n", msg.Headers)
+				fmt.Printf("ConsumerTag: %v\n", msg.ConsumerTag)
 				fmt.Printf("Payload: \n%s\n\n", msg.Body)
 
+				fmt.Println("Properties:")
+				for _, key := range valid_properties {
+					if val, err := reflections.GetField(msg, key); err == nil && val != reflect.Zero(reflect.TypeOf(val)).Interface() {
+						fmt.Printf("%s: %q\n", key, val)
+					}
+				}
+
 				count++
 				if number != 0 && count >= number {
 					ch.Close()

cmd/produce.go

@@ -93,6 +93,7 @@ To pass headers and properites, use '--headers' & '--properties' any number of t
 		returns := ch.NotifyReturn(make(chan amqp.Return, 1))
 		confirms := ch.NotifyPublish(make(chan amqp.Confirmation, 1))
 
+		fmt.Printf("Sending message with Exchange: '%s' and Key: '%s'\n", exchange, routingkey)
 		if err = ch.Publish(
 			exchange,   // exchange
 			routingkey, // routing-key