Add new queuesettings for message priority

config/config.go

@@ -26,6 +26,7 @@ type Config struct {
 		MessageTTL           int
 		DeadLetterExchange   string
 		DeadLetterRoutingKey string
+		Priority             int
 	}
 	Exchange struct {
 		Name       string

consumer/consumer.go

@@ -298,6 +298,10 @@ func sanitizeQueueArgs(cfg *config.Config) amqp.Table {
 		}
 	}
 
+	if cfg.QueueSettings.Priority > 0 {
+		args["x-max-priority"] = int32(cfg.QueueSettings.Priority)
+	}
+
 	if len(args) > 0 {
 		return args
 	}

example.conf

@@ -22,6 +22,7 @@ routingkey=somekey
 messagettl=30000
 deadLetterExchange=someexchange
 deadLetterroutingkey=someroutingkey
+priority=10
 
 [logs]
 error = /tmp/error.log