print out more information of the message

cmd/main.go

@@ -26,6 +26,59 @@ import (
 
 var insecure bool
 
+func printTitle(title string) {
+	fmt.Println("---------------------------------------------------------")
+	fmt.Println("#", title)
+	fmt.Println("---------------------------------------------------------")
+}
+
+func dumpAnnotations(title string, data map[interface{}]interface{}) {
+	if len(data) > 0 {
+		printTitle(title)
+		for k, v := range data {
+			fmt.Printf("%s => %s", k, v)
+			fmt.Println()
+		}
+	}
+}
+
+func dumpProperties(title string, data map[string]interface{}) {
+	if len(data) > 0 {
+		printTitle(title)
+		for k, v := range data {
+			fmt.Printf("%s => %s", k, v)
+			fmt.Println()
+		}
+	}
+}
+
+func dumpMessageProperties(p *amqp.MessageProperties) {
+	printTitle("Properties")
+
+	fmt.Println("Content Encoding:", p.ContentEncoding)
+	fmt.Println("Content Type:", p.ContentType)
+	fmt.Println("Message ID:", p.MessageID)
+	fmt.Println("Subject:", p.Subject)
+	fmt.Println("To:", p.To)
+
+}
+
+func dumpMessage(msg *amqp.Message) {
+
+	dumpAnnotations("Annotations", msg.Annotations)
+	dumpAnnotations("Delivery annotations", msg.DeliveryAnnotations)
+
+	dumpMessageProperties(msg.Properties)
+	dumpProperties("Application Properties", msg.ApplicationProperties)
+
+	fmt.Println("---------------------------------------------------------")
+	fmt.Println("Payload")
+	fmt.Println("---------------------------------------------------------")
+	fmt.Printf("%s", msg.GetData())
+	fmt.Println()
+	fmt.Println("=========================================================")
+}
+
 func consume(messageType string, uri string, tenant string) error {
 
 	fmt.Printf("Consuming %s from %s ...", messageType, uri)
@@ -71,6 +124,7 @@ func consume(messageType string, uri string, tenant string) error {
 	}()
 
 	fmt.Printf("Consumer running, press Ctrl+C to stop...")
+	fmt.Println()
 
 	for {
 		// Receive next message
@@ -84,7 +138,7 @@ func consume(messageType string, uri string, tenant string) error {
 			return nil
 		}
 
-		fmt.Printf("Message received: %s\n", msg.GetData())
+		dumpMessage(msg)
 	}
 }