aop
aop copied to clipboard
streamnative
AMQP on Pulsar protocol handler
### Motivation Currently, there are no metrics for AoP, it's hard to monitor AoP status. This PR will add metrics for AoP. ### Modifications Add below metrics for AoP. MetricsLabel...
### Motivation Currently, the async method `consumer.handleFlow(DEFAULT_CONSUMER_PERMIT);` in basic consume command operation doesn't handle in an async way, this may cause NPE problem in the subsequent process. ### Modifications Start...
### Motivation Currently, the cursor of the exchange is a non-durable cursor, this will cause lost exchange data. ### Modifications Create durable cursors of the exchange topic in an async...
Master Issue: #631 ### Motivation Support exchange properties ### Modifications *Describe the modifications you've done.* ### Verifying this change - [ ] Make sure that the change passes the CI...
This is a PR created by snbot to trigger the check suite in each repository.
This is a PR created by snbot to trigger the check suite in each repository.
Master Issue: #63 ### Motivation support autoDelete exchange and autoDelete queue autoDelete exchange: exchange is deleted when last queue is unbound from it autoDelete queue: queue that has had at...
