* refactor: new subscriber logic in NATS

* tests: fix raw tests

* refactor: nats completed

* chore: remove useless

* lint: fix ruff warnings

* refactor: remove useless broker methods

* refactor: move wrap handler logic to mixin class

* refactor: remove useless broker methods

* refactor: new handler consume logic

* refactore: new middlewares

* fix #690: ack message after response publish

* fix #840: broker.publish respects middlewares

* fix: correct connection closing

* fix: return published message in tests

* fix: correct middlewares

* refactor: remove useless code

* refactore: catch StopConsume at any level

* refactor: new subscriber middlewares

* refactor: nats new structure

* refactor: nats new structure

* feat: publisher middlewares

* lint: publisher middlewares hint

* tests: router middlewares & depends tests

* refactor: new logging logic

* fix: correct Windows shutdown

* refactor: fix all nats tests

* refactor: copy broker publisher middleware to all publishers

* refactor: pass all args to publisher middleware

* refactor: unify AsyncAPI names

* fix #1143: ignore Depends in AsyncAPI

* refactor: split regular and batch handlers

* refactor: split parsers

* chore: add useles comment

* fix: correct logging

* refactor: new RMQ logic

* refactor: new Kakfa

* refactor: fix Kafka consumer tests

* refactor: complete Kafka

* refactor: raw Redis

* fix: correct RMQ default ssl port

* refactor: split Redis consumers

* feat: stoppable application

* refactor: explicit NATS annotations

* refactor: remove fastapi logic from core

* refactor: remove logging args

* fix: stop RMQ Broker correct

* refactor: mv nats init args

* feat (#1252): respect Redis StreamSub last_id with consumer group

* feat: FastStream object public methods

* fix: correct Redis consumer group behavior

* fix: correct workers shutdown

* refactor: explicit NATS init

* refactor: explicit NatsBroker options

* fix: NastBroker correct publish method

* refactor: setup NATS init Doc

* refactor: explicit NatsPublisher options

* lint: ignore overrides

* chore: stash changes

* refactor: add NatsBroker publisher Docs

* refactor: detail NATS Docstrings

* refactor: fix missing RMQ typess

* refactor: make all brokers compatible with new parent

* refactor: explicit RMQ Message options

* refactor: explicit RMQ publishers options

* refactor: explicit RMQ routers

* refactor: make RabbitMQ object pydantic-independent

* refactor: make JStream pydantic independant

* refactor: merge router.publisher middlewares with routers' ones

* refactor: remove pydantic.BaseModel usages in basic classes

* feat: remove pydantic, fastapi, uvloop dependencies

* format: run formatter

* refactor: compelete RMQ annotations

* refactor: explicit Redis annotations

* refactor: compelete RMQ FastAPI annotations

* refactor: fix kafka tests

* format: run formatter

* Add some documented annotations

* refactor: start Confluent

* refactor: explicit NATS router

* chore: update tests

* style: fix some Rabbit mypy

* refactor: rm useless cache method:

* lint: Rabbit and NATS mypy

* chore: fix email

* feat: return handler object in subscriber

* lint: fix some mypy

* feat: support FastAPI response_model

* refactor: final revision

* style: run linter

* fix: correct custo, parser/decoder wrapper

* add delayed publishers registration in router

* feat: impl Nats and Redis brokers

* feat: add aiokafka broker

* refactor: correct RabbitPublisher class, add tests

* chore: add docs serve production warning

* WIP: Integrate confluent kafka broker

* Fix bug in batch publish and batch subscribe

* Lint files

* Fix build_message

* Increase reusability of consumer tests

* Fix getting stuck issue

* Reuse middleware tests

* Revert to old async confluent client to prevent getting stuck

* Reuse router test case

* add delayed kafka publisher registration with tests

* add asyncapi kafka tests

* add redis publisher delayed registration with tests, use lint.sh

* add nats publisher delayed registration with test, use lint.sh and correct docsrtings

* Reuse publish tests

* lint: fix aiokafka broker mypy

* feat (#607): add delayed publisher registration

* polish

* feat: add KafkaPublisher to confluent

* lint: fix some mypy

* Revert to old style of publishing using confluent kafka

* Fix checking whether confluent_kafka.Message object is empty or not

* Reuse parser test cases and fix one router test case

* tests: fix delay publisher confluent testcase

* tests: fix AsyncAPI FastAPI descriminator

* lint: run linters

* chore: remove useless dependencies

* chore: trigger CI

* chore: remove circular

* tests: fix Dict

* tests: fix imports

* tests: fix a batch

* tests: fix excamples

* tests: fix RMQ

* tests: correct ssl warning

* tests: fix RMQ

* tests: fix FastDepends async mock parsing

* tests: fix cli run

* tests: fix Multilock

* chore: remove useless dependencies

* tests: fix asyncpi descriminator

* tests: fix kafka tests

* tests: fix confluent

* tests: correct confluent pathching

* Fix patching in confluent broker security tests

* chore: remove useless pytest dependencies

---------

Co-authored-by: AbstractiveNord <109909821+AbstractiveNord@users.noreply.github.com>
Co-authored-by: spataphore1337 <valeriy.mrochko@gmail.com>
Co-authored-by: Spataphore <93342746+spataphore1337@users.noreply.github.com>
Co-authored-by: Kumaran Rajendhiran <kumaran@airt.ai>