Adding priority queue support to this bundle.

pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>io.github.qtrouper</groupId>
     <artifactId>qtrouper</artifactId>
-    <version>0.0.2</version>
+    <version>0.0.3</version>
     <packaging>jar</packaging>
 
     <licenses>

src/main/java/io/github/qtrouper/Trouper.java

@@ -52,7 +52,7 @@ public abstract class Trouper<C extends QueueContext> {
     private static final String EXPIRES_AT_TIMESTAMP = "x-expires-timestamp";
     private static final String EXPIRES_AT_ENABLED = "x-expires-enabled";
     private static final String CONTENT_TYPE = "text/plain";
-
+    private static final String PRIORITY = "x-max-priority";
     private final QueueConfiguration config;
     private final RabbitConnection connection;
     private final Class<? extends C> clazz;
@@ -279,7 +279,11 @@ public void start() {
         ensureExchange(exchange);
         ensureExchange(dlExchange);
         this.publishChannel = connection.newChannel();
-        connection.ensure(queueName, this.config.getNamespace(), connection.rmqOpts());
+        Map<String, Object> arguments = new HashMap<>(connection.rmqOpts());
+        if (this.config.getPriority() != 0) {
+            arguments.put(PRIORITY, this.config.getPriority());
+        }
+        connection.ensure(queueName, this.config.getNamespace(), arguments);
         connection.ensure(getRetryQueue(), dlExchange, connection.rmqOpts(exchange, queueName));
         connection.ensure(getSidelineQueue(), this.config.getNamespace(), connection.rmqOpts());
         if (config.isConsumerEnabled()) {

src/main/java/io/github/qtrouper/core/config/QueueConfiguration.java

@@ -51,6 +51,10 @@ public class QueueConfiguration {
     private RetryConfiguration retry;
     @Valid
     private SidelineConfiguration sideline;
+    @Valid
+    @Min(0)
+    @Max(255)
+    private int priority;
 
     @JsonIgnore
     public boolean isConsumerEnabled(){

src/test/java/io/github/qtrouper/TrouperTest.java

@@ -172,4 +172,21 @@ public void trouperStartWithAllEncompassingConfig() throws Exception {
         Assert.assertEquals(20, trouper.getHandlers().size());
         trouper.stop();
     }
+
+    @Test
+    public void priorityQueueTest() throws Exception {
+        val queueConfiguration = QueueConfiguration.builder()
+                .queueName("p-queue")
+                .namespace(DEFAULT_NAMESPACE)
+                .concurrency(10)
+                .priority(5)
+                .prefetchCount(10)
+                .consumerDisabled(false)
+                .retry(getRetryConfiguration(false, 10))
+                .sideline(getSidelineConfiguration(true, 10))
+                .build();
+        val trouper = getTrouperAfterStart(queueConfiguration);
+        Assert.assertEquals(5, trouper.getConfig().getPriority());
+        trouper.stop();
+    }
 }