Code

better message consumption#48

Code

Merged

musketyr merged 16 commits intomasteragorapulse/micronaut-worker:masterfrom chore/better-message-consumptionagorapulse/micronaut-worker:chore/better-message-consumptionCopy head branch name to clipboardDec 5, 2024

+659-203

Commits

Commits on Dec 3, 2024

• better message consumption

  Show description for b631ef7
  musketyr

  committed
  b631ef7

  Copy full SHA for b631ef7

• bit more docs

  musketyr

  committed
  4b7b4dd

  Copy full SHA for 4b7b4dd

• also copy the job status when copying context

  musketyr

  committed
  93b6649

  Copy full SHA for 93b6649

• added a message id to QueueMessage

  musketyr

  committed
  ffbb182

  Copy full SHA for ffbb182

• fixed concurrent message consumption

  musketyr

  committed
  4ffe4a8

  Copy full SHA for 4ffe4a8

• error handling for message consumption

  musketyr

  committed
  7efa111

  Copy full SHA for 7efa111

• fair distribution to the forked consumers

  musketyr

  committed
  0fbd62f

  Copy full SHA for 0fbd62f

• fixed test job

  musketyr

  committed
  47393fe

  Copy full SHA for 47393fe

Commits on Dec 4, 2024

• dead code clean up

  musketyr

  committed
  6d5c81c

  Copy full SHA for 6d5c81c

• improved docs

  musketyr

  committed
  fc11b58

  Copy full SHA for fc11b58

• improved docs

  musketyr

  committed
  900a249

  Copy full SHA for 900a249

Commits on Dec 5, 2024

• delete on callback for SQS v2

  musketyr

  committed
  666dd07

  Copy full SHA for 666dd07

• SQS v1 resurrection

  musketyr

  committed
  031377c

  Copy full SHA for 031377c

• SQS v1 resurrection

  musketyr

  committed
  b609524

  Copy full SHA for b609524

• Redis Queues resurrection

  musketyr

  committed
  f91cc5e

  Copy full SHA for f91cc5e

• returned deprecated method

  musketyr

  committed
  7e67941

  Copy full SHA for 7e67941