[BUG FIX] Fixing Async Consumer Logic to work based on SelectConnecti…

…on (#100)

* moved `create_connection` as a separate function in `AsyncConsumer`

* Improved aio handling

* Removed non-working tests and added pika-based Async Consumer

* Small improvements to handle failure scenarious

* tmp commit

* small fix

* Updated codebase to fully test SelectConsumerThread

* small fix

* Removed parameterized from test_connector.py

* Fixed tests and restored logic to pre-aio state

* small fix

* Added license notices

---------

Co-authored-by: NeonKirill <kirill.grim@gmail.com>

.github/workflows/unit_tests.yml

@@ -20,7 +20,7 @@ jobs:
       - name: Install dependencies
         run: |
           python -m pip install --upgrade pip
-          pip install .[aio] -r requirements/test_requirements.txt
+          pip install . -r requirements/test_requirements.txt
       - name: Run Utils Tests
         run: |
           pytest tests/test_utils.py --doctest-modules --junitxml=tests/utils-test-results.xml

README.md

@@ -69,28 +69,11 @@ Where `<queue>` is the queue to which the response will be published, and `data`
 
 ### [BETA] Asynchronous Consumers
 
-Now there is a support for async-based consumers handling based on `aio-pika` API.
-
-#### Installation
-
-To install async dependencies, run installation with `[aio]` extra:
-```shell
-pip install neon-mq-connector[aio]
-```
+Now there is a support for async-based consumers handling based on `pika.SelectConnection`
 
 #### Enabling in a code
 
-When declaring the consumer/subscriber instances, specify `async_consumer` param like follows:
-```python
-register_consumer(name="some_consumer",
-                  ...
-                  async_consumer=True,)
-register_subscriber(name="some_subscriber",
-                    ...
-                    async_consumer=True,)
-```
-
-To set creation of async consumers/subscribers globally, set the class-attribute `async_consumers_enabled` to True:
+To enable creation of async consumers/subscribers, set the class-attribute `async_consumers_enabled` to True:
 
 ```python
 from neon_mq_connector import MQConnector