New version 2.4.0

Author: sonus21

CHANGELOG.md

@@ -1,5 +1,12 @@
 # [Rqueue] New and Notable Changes
 
+## [2.4.0] - 3-Feb-2021
+
+### Added
+
+* Job Middlewares
+* Delay execution of message when it's moved to enqueue instead of consuming it immediately.
+
 ## [2.3.0] - 2-Jan-2021
 
 ### Added
@@ -175,3 +182,5 @@ Fixes:
 [2.2.0]: https://repo1.maven.org/maven2/com/github/sonus21/rqueue-core/2.2.0-RELEASE
 
 [2.3.0]: https://repo1.maven.org/maven2/com/github/sonus21/rqueue-core/2.3.0-RELEASE
+
+[2.4.0]: https://repo1.maven.org/maven2/com/github/sonus21/rqueue-core/2.4.0-RELEASE

README.md

@@ -47,14 +47,14 @@ services code is in Spring.
 * Add dependency
   * Gradle
     ```groovy
-        implementation 'com.github.sonus21:rqueue-spring-boot-starter:2.3.0-RELEASE'
+        implementation 'com.github.sonus21:rqueue-spring-boot-starter:2.4.0-RELEASE'
     ```
   * Maven
     ```xml
      <dependency>
         <groupId>com.github.sonus21</groupId>
         <artifactId>rqueue-spring-boot-starter</artifactId>
-        <version>2.3.0-RELEASE</version>
+        <version>2.4.0-RELEASE</version>
     </dependency>
     ```
 
@@ -65,14 +65,14 @@ services code is in Spring.
 * Add Dependency
   * Gradle
     ```groovy
-        implementation 'com.github.sonus21:rqueue-spring:2.3.0-RELEASE'
+        implementation 'com.github.sonus21:rqueue-spring:2.4.0-RELEASE'
     ```
   * Maven
     ```xml
      <dependency>
        <groupId>com.github.sonus21</groupId>
        <artifactId>rqueue-spring</artifactId>
-       <version>2.3.0-RELEASE</version>
+       <version>2.4.0-RELEASE</version>
      </dependency>
     ```
 

build.gradle

@@ -69,7 +69,7 @@ ext {
 
 subprojects {
     group = 'com.github.sonus21'
-    version = '2.3.0-RELEASE'
+    version = '2.4.0-RELEASE'
 
     dependencies {
         // https://mvnrepository.com/artifact/org.springframework/spring-messaging

rqueue-core/src/main/java/com/github/sonus21/rqueue/config/SimpleRqueueListenerContainerFactory.java

@@ -32,6 +32,7 @@
 import com.github.sonus21.rqueue.utils.Constants;
 import com.github.sonus21.rqueue.utils.backoff.TaskExecutionBackOff;
 import java.util.Collections;
+import java.util.LinkedList;
 import java.util.List;
 import org.springframework.core.task.AsyncTaskExecutor;
 import org.springframework.core.task.TaskExecutor;
@@ -82,7 +83,7 @@ public class SimpleRqueueListenerContainerFactory {
   // Any custom message requeue message template.
   private RqueueMessageTemplate rqueueMessageTemplate;
 
-  private List<Middleware> middlewares;
+  private final List<Middleware> middlewares = new LinkedList<>();
 
   // Any message headers that should be set, only used for message serialization
   private MessageHeaders messageHeaders;
@@ -509,12 +510,23 @@ public List<Middleware> getMiddlewares() {
   }
 
   /**
-   * Set middlewares those would be used while processing a  message.
+   * Add middlewares those would be used while processing a message. Middlewares are called in the
+   * order they are added.
    *
    * @param middlewares list of middlewares
    */
   public void setMiddlewares(List<Middleware> middlewares) {
     notEmpty(middlewares, "middlewares cannot be empty");
-    this.middlewares = middlewares;
+    this.middlewares.addAll(middlewares);
+  }
+
+  /**
+   * Add a given middleware in the chain
+   *
+   * @param middleware middleware
+   */
+  public void useMiddleware(Middleware middleware) {
+    notNull(middlewares, "middlewares cannot be null");
+    this.middlewares.add(middleware);
   }
 }