Code

Support retry letter topic #359

Code

Merged

wolfstudy merged 11 commits intoapache:masterapache/pulsar-client-go:masterfrom wuYin:reconsumewuYin/pulsar-client-go:reconsumeCopy head branch name to clipboardSep 9, 2020

+521-34

Commits

Commits on Aug 24, 2020

• Add retry router for retry letter topic

  wuYin

  committed
  c7f5ce0

  Copy full SHA for c7f5ce0

• Support reconsumeLater by attaching retry router to Consumer

  wuYin

  committed
  d54a3c8

  Copy full SHA for d54a3c8

• Add reconsumeLater test cases

  wuYin

  committed
  31e5587

  Copy full SHA for 31e5587

• Merge apache#356 into reconsume

  wuYin

  committed
  e447976

  Copy full SHA for e447976

• Remove redundant fields from reconsume message

  wuYin

  committed
  b752a81

  Copy full SHA for b752a81

• Fix style check failure

  wuYin

  committed
  def17d1

  Copy full SHA for def17d1

• Retry letter topic must be enable explicitly

  wuYin

  committed
  4a0f742

  Copy full SHA for 4a0f742

Commits on Aug 25, 2020

• Ack previous msg after when retry succeed

  wuYin

  committed
  187b24c

  Copy full SHA for 187b24c

Commits on Aug 27, 2020

• Separate cmdCh and requestsCh in connection, avoid Ack callbacks in DLQ RECEIPT handler to blocking connection's event loop.

  wuYin

  committed
  b0d8e8b

  Copy full SHA for b0d8e8b

• Add double-check in retry letter test cases.

  wuYin

  committed
  c0176b1

  Copy full SHA for c0176b1

• Fix data race at closing producer.ticker

  wuYin

  committed
  724c158

  Copy full SHA for 724c158