FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
For RPC, the metrics incorrectly included messages from temporary queues/subjects.
Now, when publishing, Reply messages are ignored and when consuming, Response messages are ignored.
Type of change
[x] Bug fix (a non-breaking change that resolves an issue)
Checklist
[x] My code adheres to the style guidelines of this project (scripts/lint.sh shows no errors)
[x] I have conducted a self-review of my own code
[ ] I have made the necessary changes to the documentation
[x] My changes do not generate any new warnings
[x] I have added tests to validate the effectiveness of my fix or the functionality of my new feature
[x] Both new and existing unit tests pass successfully on my local environment by running scripts/test-cov.sh
[x] I have ensured that static analysis tests are passing by running scripts/static-analysis.sh
[ ] I have included code examples to illustrate the modifications
Description
For RPC, the metrics incorrectly included messages from temporary queues/subjects. Now, when publishing,
Replymessages are ignored and when consuming,Responsemessages are ignored.Type of change
Checklist
scripts/lint.shshows no errors)scripts/test-cov.shscripts/static-analysis.sh