Code

Add Consumer Flow Control Strategies#340

Code

Closed

henry701 wants to merge 15 commits intorabbitmq:mainrabbitmq/rabbitmq-stream-java-client:mainfrom

henry701:consumer-flow-controlhenry701/rabbitmq-stream-java-client:consumer-flow-controlCopy head branch name to clipboard

Commits

Commits on May 28, 2023

• Add flow control strategy mechanism

  Show description for 7add606
  henry701

  committed
  7add606

  Copy full SHA for 7add606

• Add test for flow control strategy main handler methods

  henry701

  committed
  2fbd85f

  Copy full SHA for 2fbd85f

Commits on Jun 10, 2023

• Abstract Client instance away from flow control strategy, create ConsumerStatisticRecorder and a flow control strategy that uses it

  henry701

  committed
  7175c3d

  Copy full SHA for 7175c3d

Commits on Jun 11, 2023

• Abstract dependency on Client away from public Flow Control classes by using an adapter for the callback interface

  henry701

  committed
  9a08c72

  Copy full SHA for 9a08c72

Commits on Jun 13, 2023

• Remove obsolete 'initialCredits' and 'additionalCredits' parameters

  henry701

  committed
  704e7b0

  Copy full SHA for 704e7b0

• Fix tests by fixing control flow callback adapter delegation

  henry701

  committed
  f94be95

  Copy full SHA for f94be95

Commits on Jun 16, 2023

• Add integrated test and fix issues discovered in the initial flow control implementation

  henry701

  committed
  b4a0b44

  Copy full SHA for b4a0b44

Commits on Jun 17, 2023

• Fix consumer flow on reconnection situations and add integrated test for it. Also add shortcuts on Consumer to avoid users having to use impl classes for flow control. Also, remove the verbose buil…

  Show description for 13102e7
  henry701

  committed
  13102e7

  Copy full SHA for 13102e7

Commits on Jun 21, 2023

• Remove redundant 0 assignments to trackerCount field

  henry701

  committed
  a54100b

  Copy full SHA for a54100b

Commits on Jun 25, 2023

• Change lifecycle of each consumer flow control strategy instance to be per-subscription

  henry701

  committed
  7250c8a

  Copy full SHA for 7250c8a

Commits on Jun 28, 2023

• Change MessageHandler.Context.markHandled to receive no parameters, and use it in one of the integrated tests to mark messages as handled

  henry701

  committed
  70486f4

  Copy full SHA for 70486f4

• Remove MessageHandlingListenerConsumerBuilderAccessor

  henry701

  committed
  a156eb0

  Copy full SHA for a156eb0

Commits on Jul 1, 2023

• Change lifecycle of ConsumerFlowControlStrategy to be 1-1 with SubscriptionTracker, removing subscription and stream name parameters

  henry701

  committed
  09f3cb7

  Copy full SHA for 09f3cb7

• Merge branch 'main' into consumer-flow-control

  Show description for 22060e9
  henry701

  committed
  22060e9

  Copy full SHA for 22060e9

Commits on Jul 4, 2023

• Add specific error for when client is not initialized

  henry701

  committed
  17835b0

  Copy full SHA for 17835b0