0.8.0

.github/workflows/unit_tests.yml

@@ -4,53 +4,58 @@ on:
   workflow_dispatch:
 
 jobs:
-  unit_tests:
+  backwards_compat_tests:
     strategy:
       matrix:
-        python-version: [ 3.7, 3.8, 3.9, '3.10' ]
+        python-version: [ '3.8', '3.10']
       max-parallel: 1
     timeout-minutes: 30
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v4
       - name: Set up python ${{ matrix.python-version }}
-        uses: actions/setup-python@v2
+        uses: actions/setup-python@v5
         with:
           python-version: ${{ matrix.python-version }}
       - name: Install dependencies
         run: |
           python -m pip install --upgrade pip
           pip install . -r requirements/test_requirements.txt
-      - name: Get Credential
-        run: |
-          mkdir -p ~/.local/share/neon
-          echo $CONNECTOR_CONFIG > ~/.local/share/neon/credentials.json
-        shell: bash
-        env:
-          CONNECTOR_CONFIG: ${{secrets.CONNECTOR_CONFIG}}
-      - name: Run Utils Tests
+      - name: Run Backward Compatibility Tests
         run: |
-          pytest tests/test_utils.py --doctest-modules --junitxml=tests/utils-test-results.xml
-      - name: Upload Utils test results
-        uses: actions/upload-artifact@v2
+          pytest tests/backward_compat_tests.py --doctest-modules --junitxml=tests/backward-compatibility-test-results.xml
+      - name: Upload Backward Compatibility test results
+        uses: actions/upload-artifact@v4
         with:
-          name: utils-test-results
-          path: tests/utils-test-results.xml
-      - name: Run Connector Tests
-        run: |
-          pytest tests/test_connector.py --doctest-modules --junitxml=tests/connector-test-results.xml
-#        env:
-#          MQ_TESTING: 1
-      - name: Upload Connector test results
-        uses: actions/upload-artifact@v2
+          name: backward-compatibility-test-results-${{ matrix.python-version }}
+          path: tests/backward-compatibility-test-results.xml
+  unit_tests:
+    strategy:
+      matrix:
+        python-version: [ '3.8', '3.9', '3.10', '3.11', '3.12' ]
+    timeout-minutes: 30
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Set up python ${{ matrix.python-version }}
+        uses: actions/setup-python@v5
         with:
-          name: connector-test-results
-          path: tests/connector-test-results.xml
-      - name: Run Backward Compatibility Tests
+          python-version: ${{ matrix.python-version }}
+      - name: Install apt dependencies
         run: |
-          pytest tests/test_backward_compatibility.py --doctest-modules --junitxml=tests/backward-compatibility-test-results.xml
-      - name: Upload Backward Compatibility test results
-        uses: actions/upload-artifact@v2
+          sudo apt update
+          sudo apt install -y rabbitmq-server
+
+      - name: Install dependencies
+        run: |
+          python -m pip install --upgrade pip
+          pip install . -r requirements/test_requirements.txt
+
+      - name: Run Unit Tests
+        run: |
+          pytest tests --doctest-modules --junitxml=tests/test-results.xml
+      - name: Upload test results
+        uses: actions/upload-artifact@v4
         with:
-          name: backward-compatibility-test-results
-          path: tests/backward-compatibility-test-results.xml
+          name: test-results-${{ matrix.python-version }}
+          path: tests/test-results.xml

CHANGELOG.md

@@ -1,52 +1,176 @@
 # Changelog
 
-## [0.7.1](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1) (2023-12-11)
+## [0.7.2a21](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a21) (2025-01-27)
 
-[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a5...0.7.1)
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a20...0.7.2a21)
 
-**Closed issues:**
+**Merged pull requests:**
+
+- Update to ensure `message_id` is not None [\#121](https://github.com/NeonGeckoCom/neon_mq_connector/pull/121) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a20](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a20) (2025-01-24)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a19...0.7.2a20)
+
+**Merged pull requests:**
+
+- Update param name to avoid conflict with `threading.Thread` [\#120](https://github.com/NeonGeckoCom/neon_mq_connector/pull/120) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a19](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a19) (2025-01-24)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a18...0.7.2a19)
+
+**Merged pull requests:**
+
+- Handle RMQ checks with default vhost [\#119](https://github.com/NeonGeckoCom/neon_mq_connector/pull/119) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a18](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a18) (2025-01-23)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a17...0.7.2a18)
+
+**Merged pull requests:**
 
-- remove hard-coded configuration of log level [\#87](https://github.com/NeonGeckoCom/neon_mq_connector/issues/87)
+- Improved Startup Connectivity Checks [\#117](https://github.com/NeonGeckoCom/neon_mq_connector/pull/117) ([NeonDaniel](https://github.com/NeonDaniel))
 
-## [0.7.1a5](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a5) (2023-12-09)
+## [0.7.2a17](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a17) (2025-01-23)
 
-[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a4...0.7.1a5)
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a16...0.7.2a17)
 
 **Merged pull requests:**
 
-- Reduce message emit log to `DEBUG` [\#93](https://github.com/NeonGeckoCom/neon_mq_connector/pull/93) ([NeonDaniel](https://github.com/NeonDaniel))
+- Update copyright notices to 2025 [\#118](https://github.com/NeonGeckoCom/neon_mq_connector/pull/118) ([NeonDaniel](https://github.com/NeonDaniel))
 
-## [0.7.1a4](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a4) (2023-08-11)
+## [0.7.2a16](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a16) (2025-01-23)
 
-[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a3...0.7.1a4)
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a15...0.7.2a16)
 
 **Merged pull requests:**
 
-- Update `message_id` handling for response routing [\#92](https://github.com/NeonGeckoCom/neon_mq_connector/pull/92) ([NeonDaniel](https://github.com/NeonDaniel))
+- Support Select Connections in `emit_mq_message` [\#115](https://github.com/NeonGeckoCom/neon_mq_connector/pull/115) ([NeonDaniel](https://github.com/NeonDaniel))
 
-## [0.7.1a3](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a3) (2023-07-28)
+## [0.7.2a15](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a15) (2025-01-23)
 
-[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a2...0.7.1a3)
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a14...0.7.2a15)
 
 **Merged pull requests:**
 
-- Update message\_id handling for iris compat [\#91](https://github.com/NeonGeckoCom/neon_mq_connector/pull/91) ([NeonDaniel](https://github.com/NeonDaniel))
+- Update default async consumer behavior and configuration [\#113](https://github.com/NeonGeckoCom/neon_mq_connector/pull/113) ([NeonDaniel](https://github.com/NeonDaniel))
 
-## [0.7.1a2](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a2) (2023-07-27)
+## [0.7.2a14](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a14) (2025-01-22)
 
-[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a1...0.7.1a2)
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a13...0.7.2a14)
 
 **Merged pull requests:**
 
-- Update logging and response routing [\#89](https://github.com/NeonGeckoCom/neon_mq_connector/pull/89) ([NeonDaniel](https://github.com/NeonDaniel))
+- Handle errors if MQ is not connected at service launch [\#116](https://github.com/NeonGeckoCom/neon_mq_connector/pull/116) ([NeonDaniel](https://github.com/NeonDaniel))
 
-## [0.7.1a1](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a1) (2023-07-26)
+## [0.7.2a13](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a13) (2025-01-17)
 
-[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.0...0.7.1a1)
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a12...0.7.2a13)
 
 **Merged pull requests:**
 
-- Bug Fix: Setting Generated Message ID as default value, skipping it while already set [\#90](https://github.com/NeonGeckoCom/neon_mq_connector/pull/90) ([NeonKirill](https://github.com/NeonKirill))
+- Update logging in select consumer close [\#112](https://github.com/NeonGeckoCom/neon_mq_connector/pull/112) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a12](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a12) (2025-01-16)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a11...0.7.2a12)
+
+**Merged pull requests:**
+
+- Resolve observed connection errors [\#111](https://github.com/NeonGeckoCom/neon_mq_connector/pull/111) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a11](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a11) (2025-01-14)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a10...0.7.2a11)
+
+**Merged pull requests:**
+
+- Define `shutdown` method for NeonMQHandler with unit test coverage [\#110](https://github.com/NeonGeckoCom/neon_mq_connector/pull/110) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a10](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a10) (2025-01-13)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a9...0.7.2a10)
+
+**Merged pull requests:**
+
+- Fix ` reconnection` with unit test coverage [\#109](https://github.com/NeonGeckoCom/neon_mq_connector/pull/109) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a9](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a9) (2025-01-02)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a8...0.7.2a9)
+
+**Merged pull requests:**
+
+- Improve connection close and error handling [\#107](https://github.com/NeonGeckoCom/neon_mq_connector/pull/107) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a8](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a8) (2024-12-11)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a7...0.7.2a8)
+
+**Merged pull requests:**
+
+- Update tests to use temporary RMQ instance and improve coverage [\#104](https://github.com/NeonGeckoCom/neon_mq_connector/pull/104) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a7](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a7) (2024-12-05)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a6...0.7.2a7)
+
+**Merged pull requests:**
+
+- \[Bug Fix\] Fixing issue with reopenning connection on consumers [\#103](https://github.com/NeonGeckoCom/neon_mq_connector/pull/103) ([NeonKirill](https://github.com/NeonKirill))
+
+## [0.7.2a6](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a6) (2024-12-05)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a5...0.7.2a6)
+
+**Merged pull requests:**
+
+- Eliminated "self joining" problem in consumer threads and added graceful restarts handling [\#102](https://github.com/NeonGeckoCom/neon_mq_connector/pull/102) ([NeonKirill](https://github.com/NeonKirill))
+
+## [0.7.2a5](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a5) (2024-12-03)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a4...0.7.2a5)
+
+**Merged pull requests:**
+
+- \[BUG FIX\] Fixing Async Consumer Logic to work based on SelectConnection [\#100](https://github.com/NeonGeckoCom/neon_mq_connector/pull/100) ([NeonKirill](https://github.com/NeonKirill))
+
+## [0.7.2a4](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a4) (2024-11-21)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a3...0.7.2a4)
+
+**Implemented enhancements:**
+
+- \[FEAT\] Update tests to run without org secrets [\#97](https://github.com/NeonGeckoCom/neon_mq_connector/issues/97)
+
+**Merged pull requests:**
+
+- \[FEAT\] Async-based Consumers Support [\#99](https://github.com/NeonGeckoCom/neon_mq_connector/pull/99) ([NeonKirill](https://github.com/NeonKirill))
+
+## [0.7.2a3](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a3) (2024-09-12)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a2...0.7.2a3)
+
+**Merged pull requests:**
+
+- Update OVOS dependencies [\#98](https://github.com/NeonGeckoCom/neon_mq_connector/pull/98) ([NeonDaniel](https://github.com/NeonDaniel))
+
+## [0.7.2a2](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a2) (2024-04-25)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a1...0.7.2a2)
+
+**Merged pull requests:**
+
+- feat: allow ovos-utils 0.1.0 [\#96](https://github.com/NeonGeckoCom/neon_mq_connector/pull/96) ([mikejgray](https://github.com/mikejgray))
+
+## [0.7.2a1](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a1) (2024-03-30)
+
+[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1...0.7.2a1)
+
+**Fixed bugs:**
+
+- Fixing Issues with Consumers termination [\#95](https://github.com/NeonGeckoCom/neon_mq_connector/pull/95) ([NeonKirill](https://github.com/NeonKirill))
 
 
 

LICENSE.md

@@ -1,6 +1,6 @@
 # NEON AI (TM) SOFTWARE, Software Development Kit & Application Development System
 # All trademark and other rights reserved by their respective owners
-# Copyright 2008-2021 Neongecko.com Inc.
+# Copyright 2008-2025 Neongecko.com Inc.
 # BSD-3 License
 
 Redistribution and use in source and binary forms, with or without modification, are permitted provided that the

README.md

@@ -66,3 +66,27 @@ A response may be sent via:
                        )
 ```
 Where `<queue>` is the queue to which the response will be published, and `data` is a `bytes` response (generally a `base64`-encoded `dict`).
+
+### Asynchronous Consumers
+By default, async-based consumers handling based on `pika.SelectConnection` will
+be used
+
+#### Override use of async consumers
+
+There are a few methods to disable use of async consumers/subscribers.
+
+1. To disable async consumers for a particular class/object, 
+set the class-attribute `async_consumers_enabled` to `False`:
+
+   ```python
+   from neon_mq_connector import MQConnector
+
+   class MQConnectorChild(MQConnector):
+      async_consumers_enabled = False
+   ```
+2. To disable the use of async consumers at runtime, set the `MQ_ASYNC_CONSUMERS`
+envvar to `False`
+
+   ```shell
+   export MQ_ASYNC_CONSUMERS=false
+   ```

neon_mq_connector/__init__.py

@@ -1,6 +1,6 @@
 # NEON AI (TM) SOFTWARE, Software Development Kit & Application Framework
 # All trademark and other rights reserved by their respective owners
-# Copyright 2008-2022 Neongecko.com Inc.
+# Copyright 2008-2025 Neongecko.com Inc.
 # Contributors: Daniel McKnight, Guy Daniels, Elon Gasper, Richard Leeds,
 # Regina Bloomstine, Casimiro Ferreira, Andrii Pernatii, Kirill Hrymailo
 # BSD-3 License

neon_mq_connector/config.py

@@ -1,6 +1,6 @@
 # NEON AI (TM) SOFTWARE, Software Development Kit & Application Framework
 # All trademark and other rights reserved by their respective owners
-# Copyright 2008-2022 Neongecko.com Inc.
+# Copyright 2008-2025 Neongecko.com Inc.
 # Contributors: Daniel McKnight, Guy Daniels, Elon Gasper, Richard Leeds,
 # Regina Bloomstine, Casimiro Ferreira, Andrii Pernatii, Kirill Hrymailo
 # BSD-3 License