Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

At least once message guarantee ✌️ #1

Merged
merged 6 commits into from
Nov 1, 2019
Merged

At least once message guarantee ✌️ #1

merged 6 commits into from
Nov 1, 2019

Commits on Oct 30, 2019

  1. 1. Reduced zset calls

    2. Use channel to broadcast updated detail
    3. Schedule tasks to move messages.
    4. At least once message guarantee
    sonus21 committed Oct 30, 2019
    Configuration menu
    Copy the full SHA
    1b47bfa View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    c422554 View commit details
    Browse the repository at this point in the history

Commits on Oct 31, 2019

  1. Configuration menu
    Copy the full SHA
    385260a View commit details
    Browse the repository at this point in the history
  2. Merge branch 'dev' of github-sonus21:sonus21/rqueue into dev

    # Conflicts:
    #	rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/ApplicationTest.java
    #	rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/ApplicationWithAutoStartSchedulerDisabledTest.java
    #	rqueue-spring-boot-starter/src/test/resources/application-disabled.properties
    #	rqueue/src/main/java/com/github/sonus21/rqueue/core/MessageScheduler.java
    #	rqueue/src/main/java/com/github/sonus21/rqueue/listener/RqueueMessageListenerContainer.java
    sonus21 committed Oct 31, 2019
    Configuration menu
    Copy the full SHA
    cf695d3 View commit details
    Browse the repository at this point in the history
  3. Ignore test temoporarly.

    sonus21 committed Oct 31, 2019
    Configuration menu
    Copy the full SHA
    11abc3e View commit details
    Browse the repository at this point in the history

Commits on Nov 1, 2019

  1. Message Scheduler:

    1. multiple tasks were getting submitted due to race concurrent message events
    2. Do not cancel already cancelled/done tasks
    3. Do not call recursively to execute script => this can lead to error in the local time stored in scheduled tasks
    4. Tasks for non-delayed queued were also scheduled
    
    RqueueMessageListenerContainer
    
    1. When received message is null => queue is empty sleep for polling interval instead of polling again
    2. Do not consider delayed queue workers as they are scheduled separately.
    
    push-message.lua
    Wrong data type was returned leading to error in task scheduling due to null value
    
    Added multiple test scenarios to verify different condition.
    sonus21 committed Nov 1, 2019
    Configuration menu
    Copy the full SHA
    f0ed1b2 View commit details
    Browse the repository at this point in the history