Code

Add dynamic-batch publishing option#649

Code

Merged

acogoluegnes merged 13 commits intomainrabbitmq/rabbitmq-stream-java-client:mainfrom dynamic-batch-publishingrabbitmq/rabbitmq-stream-java-client:dynamic-batch-publishingCopy head branch name to clipboardNov 7, 2024

+1,126-476

Commits

Commits on Nov 5, 2024

• Experiment with dynamic-batch approach for publishing

  acogoluegnes

  committed
  16396df

  Copy full SHA for 16396df

• Refactor message accumulator abstraction for dynamic batching

  acogoluegnes

  committed
  36c264d

  Copy full SHA for 36c264d

• Add dynamic-batch message accumulator

  acogoluegnes

  committed
  817d57a

  Copy full SHA for 817d57a

• Clean up producer code

  acogoluegnes

  committed
  127e3ca

  Copy full SHA for 127e3ca

Commits on Nov 6, 2024

• Test against dynamic-batch message accumulator

  acogoluegnes

  committed
  f2ce304

  Copy full SHA for f2ce304

• Add helper for message accumulator

  acogoluegnes

  committed
  8c54607

  Copy full SHA for 8c54607

• Run test suite against both versions of message accumulator

  Show description for 517926e
  acogoluegnes

  committed
  517926e

  Copy full SHA for 517926e

• Add dynamic batch option in producer builder

  acogoluegnes

  committed
  fa5e0a3

  Copy full SHA for fa5e0a3

• Fix producer builder duplication

  acogoluegnes

  committed
  6d51653

  Copy full SHA for 6d51653

• Stop thread in DynamicBatch

  acogoluegnes

  committed
  40d58c8

  Copy full SHA for 40d58c8

• Use virtual threads if available in dynamic batch support class

  acogoluegnes

  committed
  b56df00

  Copy full SHA for b56df00

• Introduce replay argument in dynamic batch support class

  acogoluegnes

  committed
  f582f7d

  Copy full SHA for f582f7d

• Test dynamic batch publishing on CI

  acogoluegnes

  committed
  3052454

  Copy full SHA for 3052454