Code

Fix flush interval#338

Code

Merged

Gsantomaggio merged 13 commits intorabbitmq:mainrabbitmq/rabbitmq-stream-go-client:mainfrom Darthmineboy:fix-flush-intervalDarthmineboy/rabbitmq-stream-go-client:fix-flush-intervalCopy head branch name to clipboardJul 24, 2024

+91-48

Commits

Commits on Jul 22, 2024

• test that consumer offset is committed after flush interval

  Darthmineboy

  committed
  f3764f5

• fix auto commit flush interval not triggered with constant stream of incoming messages

  Darthmineboy

  committed
  4572555

• use time.Since()

  Darthmineboy

  committed
  fca87f2

• update ginkgo as test summary is not showing

  Show description for 8f6c4c9
  Darthmineboy

  committed
  8f6c4c9

• add test reason with number of messages received

  Darthmineboy

  committed
  4fd81d3

• try up to 50 messages

  Darthmineboy

  committed
  5b4d151

• fix data race

  Darthmineboy

  committed
  6841253

• tidy

  Darthmineboy

  committed
  70855d9

• Merge branch 'main' into fix-flush-interval

  Gsantomaggio

  authored
  35c147f

Commits on Jul 23, 2024

• move resetting messageCountBeforeStorage to cacheStoreOffset()

  Darthmineboy

  committed
  a293605

• Merge remote-tracking branch 'origin/fix-flush-interval' into fix-flush-interval

  Darthmineboy

  committed
  623b860

• fix potential data race with messageCountBeforeStorage when closing consumer

  Darthmineboy

  committed
  efe00b9

• have increaseMessageCountBeforeStorage() return current messageCountBeforeStorage so that we don't need getMessageCountBeforeStorage() and request the mutex twice

  Darthmineboy

  committed
  f76ca3c