Multiple Fixes (#159)

Author: sonus21

.circleci/config.yml

@@ -117,7 +117,7 @@ aliases:
 executors:
   rqueue-executor:
     machine:
-      image: ubuntu-1604:202007-01
+      image: ubuntu-2004:202201-02
 
     working_directory: ~/repo
 
@@ -139,7 +139,7 @@ build_steps: &build_steps
           # fallback to using the latest cache if no exact match is found
           - v1-dependencies-
 
-    - run: gradle dependencies
+    - run: ./gradlew dependencies
     - save_cache:
         paths:
           - ~/.gradle

CHANGELOG.md

@@ -1,5 +1,17 @@
 # [Rqueue] New and Notable Changes
 
+### [2.10.2] - 15-Jul-2022
+
+### Fixes
+
+* Message status is not enqueued only, but it should be successful, failed etc
+* Weighted queue with size 1 was not working
+* Deleted message reappears
+
+### Features
+
+* Disable Rqueue using `rqueue.enabled` flag
+
 ### [2.10.1] - 18-Oct-2021
 
 * Fixes for concurrency when task executor is provided see issue #[122]
@@ -281,4 +293,6 @@ Fixes:
 
 [2.10.1]: https://repo1.maven.org/maven2/com/github/sonus21/rqueue-core/2.10.1-RELEASE
 
+[2.10.2]: https://repo1.maven.org/maven2/com/github/sonus21/rqueue-core/2.10.2-RELEASE
+
 [122]: https://github.com/sonus21/rqueue/issues/122

README.md

@@ -19,7 +19,7 @@ well, where all services code is in Spring.
 
 ## Features
 
-* **Instant delivery** : Instant execute this message
+* **Instant delivery** : Instant execute this message in the background
 * **Message scheduling** : A message can be scheduled for any arbitrary period
 * **Unique message** : Unique message processing for a queue based on the message id
 * **Periodic message** : Process same message at certain interval
@@ -71,14 +71,14 @@ Release Version: [Maven central](https://search.maven.org/search?q=g:com.github.
 * Add dependency
   * Gradle
     ```groovy
-        implementation 'com.github.sonus21:rqueue-spring-boot-starter:2.10.1-RELEASE'
+        implementation 'com.github.sonus21:rqueue-spring-boot-starter:2.10.2-RELEASE'
     ```
   * Maven
     ```xml
      <dependency>
         <groupId>com.github.sonus21</groupId>
         <artifactId>rqueue-spring-boot-starter</artifactId>
-        <version>2.10.1-RELEASE</version>
+        <version>2.10.2-RELEASE</version>
     </dependency>
     ```
 
@@ -91,14 +91,14 @@ Release Version: [Maven central](https://search.maven.org/search?q=g:com.github.
 * Add Dependency
   * Gradle
     ```groovy
-        implementation 'com.github.sonus21:rqueue-spring:2.10.1-RELEASE'
+        implementation 'com.github.sonus21:rqueue-spring:2.10.2-RELEASE'
     ```
   * Maven
     ```xml
      <dependency>
        <groupId>com.github.sonus21</groupId>
        <artifactId>rqueue-spring</artifactId>
-       <version>2.10.1-RELEASE</version>
+       <version>2.10.2-RELEASE</version>
      </dependency>
     ```
 
@@ -255,12 +255,32 @@ a
 PR/[issue](https://github.com/sonus21/rqueue/issues/new?template=i-m-using-rqueue.md&title=Add+my+organisation+in+Rqueue+Users)
 .**
 
-<a href="https://tuneyou.com/"><img alt="TuneYou" src="https://raw.githubusercontent.com/sonus21/rqueue/master/docs/static/users/tuneyou.png" width="150" align="middle"/></a>
+<a href="https://tuneyou.com"><img alt="TuneYou" src="https://raw.githubusercontent.com/sonus21/rqueue/master/docs/static/users/tuneyou.png" width="150" align="middle"/></a>
 &nbsp;&nbsp;
 <a href="https://www.pokerstarssports.eu"><img  alt="PokerStars" src="https://raw.githubusercontent.com/sonus21/rqueue/master/docs/static/users/pokerstars.png" width="250" align="middle"/></a>
 &nbsp;&nbsp;
-<a href="https://bitbot.plus/"><img src="https://raw.githubusercontent.com/sonus21/rqueue/master/docs/static/users/bitbot.png" alt="Bitbot" height="60" align="middle"/></a>
+<a href="https://bitbot.plus"><img src="https://raw.githubusercontent.com/sonus21/rqueue/master/docs/static/users/bitbot.png" alt="Bitbot" height="60" align="middle"/></a>
 &nbsp;&nbsp;
+<a href="https://www.chaotiinfo.cn"><img src="https://raw.githubusercontent.com/sonus21/rqueue/master/docs/static/users/chaoti-info.png" alt="CHAOTI INFO TECH(SHENZHEN)" height="60" align="middle"/></a>
+&nbsp;&nbsp;
+
+<!---- Signing Key
+~/.gradle/gradle.properties file
+
+sonatypeUsername=xyz
+sonatypePassword=xyz
+signing.keyId=371EDCC6
+signing.password=xyz
+signing.secretKeyRingFile=/Users/sonu/.gnupg/secring.gpg
+
+
+For signing generate gpg key using gpg tool using `gpg --gen-key`
+
+signing.password is gpg key password
+signing.keyId is last 8 character of gpg key, find using `gpg -K`
+signing.secretKeyRingFile=/Users/sonu/.gnupg/secring.gpg generate this as `gpg --keyring secring.gpg --export-secret-keys > ~/.gnupg/secring.gpg`
+
+--->
 
 ## Support
 

build.gradle

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

docs/static/users/chaoti-info.png

@@ -14,7 +14,7 @@ artifacts {
     archives javadocJar
 }
 
-ext.isNotCi = !"true".equals(System.getenv("CI"))
+ext.isNotCi = "true" != System.getenv("CI")
 signing {
     required { isNotCi && gradle.taskGraph.hasTask("uploadArchives") }
     sign configurations.archives

gradle/code-signing.gradle

@@ -23,6 +23,7 @@
 import java.lang.annotation.Target;
 import org.springframework.core.annotation.AliasFor;
 import org.springframework.stereotype.Component;
+
 /**
  * Indicates that an annotated class is a message listener
  *

rqueue-core/src/main/java/com/github/sonus21/rqueue/annotation/MessageListener.java

@@ -53,6 +53,7 @@
 @Retention(RetentionPolicy.RUNTIME)
 @Documented
 public @interface RqueueListener {
+
   /**
    * List of unique queues. Queues can be defined by their name, placeholder that would be resolved
    * to properties file or could be list of comma separated queue names.

rqueue-core/src/main/java/com/github/sonus21/rqueue/annotation/RqueueListener.java

@@ -19,6 +19,7 @@
 import java.time.Duration;
 
 public interface RqueueLockManager {
+
   boolean acquireLock(String lockKey, String lockValue, Duration duration);
 
   boolean releaseLock(String lockKey, String lockValue);

rqueue-core/src/main/java/com/github/sonus21/rqueue/common/RqueueLockManager.java

@@ -34,6 +34,7 @@
 
 @Slf4j
 public class RqueueRedisTemplate<V extends Serializable> {
+
   protected RedisTemplate<String, V> redisTemplate;
 
   public RqueueRedisTemplate(RedisConnectionFactory redisConnectionFactory) {