Create durable exchange topic cursor for queue

[gaoran10]

Motivation

Currently, for AoP, messages of the queue topic are only index data, the original data are in the exchange topic, the AmqpConsumer needs to get the original message data from the exchange topic and send it to the client, if messages in the exchange topic are clean up, the AmqpConsumer will not get the data, so queue topics need durable cursors of exchange topic to make sure the original data exists.

Notable

This PR will cause the exchange topic can't be cleaned up because the queue only handles part of the exchange data, only these index positions could be acknowledged. I'll create a new PR to fix this problem.

Modifications

Create durable cursors of the exchange topic for each queue in an async way.

Does this pull request potentially affect one of the following parts:

If yes was chosen, please highlight the changes

• Dependencies (does it add or upgrade a dependency): (no)
• The public API: (no)
• The schema: (no)
• The default values of configurations: (no)
• The wire protocol: (no)
• The rest endpoints: (no)
• The admin cli options: (no)
• Anything that affects deployment: (no)

Documentation

Check the box below.

Need to update docs?

• doc-required

  (If you need help on updating docs, create a doc issue)

• no-need-doc

  (Please explain why)

• doc

  (If this PR contains doc changes)

[GhostBoyBoy]

LGTM

[gaoran10]

I create a PR #698 to fix the exchange data cleanup problem.