Skip to content

Commit 43f9dd1

Browse files
NeonDanielNeonDaniel
authored
0.8.0 (#122)
# Changelog ## [0.7.2a21](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a21) (2025-01-27) [Full Changelog](0.7.2a20...0.7.2a21) **Merged pull requests:** - Update to ensure `message_id` is not None [\#121](#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](0.7.2a19...0.7.2a20) **Merged pull requests:** - Update param name to avoid conflict with `threading.Thread` [\#120](#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](0.7.2a18...0.7.2a19) **Merged pull requests:** - Handle RMQ checks with default vhost [\#119](#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](0.7.2a17...0.7.2a18) **Merged pull requests:** - Improved Startup Connectivity Checks [\#117](#117) ([NeonDaniel](https://github.com/NeonDaniel)) ## [0.7.2a17](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a17) (2025-01-23) [Full Changelog](0.7.2a16...0.7.2a17) **Merged pull requests:** - Update copyright notices to 2025 [\#118](#118) ([NeonDaniel](https://github.com/NeonDaniel)) ## [0.7.2a16](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a16) (2025-01-23) [Full Changelog](0.7.2a15...0.7.2a16) **Merged pull requests:** - Support Select Connections in `emit_mq_message` [\#115](#115) ([NeonDaniel](https://github.com/NeonDaniel)) ## [0.7.2a15](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a15) (2025-01-23) [Full Changelog](0.7.2a14...0.7.2a15) **Merged pull requests:** - Update default async consumer behavior and configuration [\#113](#113) ([NeonDaniel](https://github.com/NeonDaniel)) ## [0.7.2a14](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a14) (2025-01-22) [Full Changelog](0.7.2a13...0.7.2a14) **Merged pull requests:** - Handle errors if MQ is not connected at service launch [\#116](#116) ([NeonDaniel](https://github.com/NeonDaniel)) ## [0.7.2a13](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a13) (2025-01-17) [Full Changelog](0.7.2a12...0.7.2a13) **Merged pull requests:** - Update logging in select consumer close [\#112](#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](0.7.2a11...0.7.2a12) **Merged pull requests:** - Resolve observed connection errors [\#111](#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](0.7.2a10...0.7.2a11) **Merged pull requests:** - Define `shutdown` method for NeonMQHandler with unit test coverage [\#110](#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](0.7.2a9...0.7.2a10) **Merged pull requests:** - Fix ` reconnection` with unit test coverage [\#109](#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](0.7.2a8...0.7.2a9) **Merged pull requests:** - Improve connection close and error handling [\#107](#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](0.7.2a7...0.7.2a8) **Merged pull requests:** - Update tests to use temporary RMQ instance and improve coverage [\#104](#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](0.7.2a6...0.7.2a7) **Merged pull requests:** - \[Bug Fix\] Fixing issue with reopenning connection on consumers [\#103](#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](0.7.2a5...0.7.2a6) **Merged pull requests:** - Eliminated "self joining" problem in consumer threads and added graceful restarts handling [\#102](#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](0.7.2a4...0.7.2a5) **Merged pull requests:** - \[BUG FIX\] Fixing Async Consumer Logic to work based on SelectConnection [\#100](#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](0.7.2a3...0.7.2a4) **Implemented enhancements:** - \[FEAT\] Update tests to run without org secrets [\#97](#97) **Merged pull requests:** - \[FEAT\] Async-based Consumers Support [\#99](#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](0.7.2a2...0.7.2a3) **Merged pull requests:** - Update OVOS dependencies [\#98](#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](0.7.2a1...0.7.2a2) **Merged pull requests:** - feat: allow ovos-utils 0.1.0 [\#96](#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](0.7.1...0.7.2a1) **Fixed bugs:** - Fixing Issues with Consumers termination [\#95](#95) ([NeonKirill](https://github.com/NeonKirill)) \* *This Changelog was automatically generated by [github_changelog_generator](https://github.com/github-changelog-generator/github-changelog-generator)*
2 parents b9566b2 + 83bc863 commit 43f9dd1

28 files changed

+1874
-397
lines changed

‎.github/workflows/unit_tests.yml

Lines changed: 37 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -4,53 +4,58 @@ on:
44
workflow_dispatch:
55

66
jobs:
7-
unit_tests:
7+
backwards_compat_tests:
88
strategy:
99
matrix:
10-
python-version: [ 3.7, 3.8, 3.9, '3.10' ]
10+
python-version: [ '3.8', '3.10']
1111
max-parallel: 1
1212
timeout-minutes: 30
1313
runs-on: ubuntu-latest
1414
steps:
15-
- uses: actions/checkout@v2
15+
- uses: actions/checkout@v4
1616
- name: Set up python ${{ matrix.python-version }}
17-
uses: actions/setup-python@v2
17+
uses: actions/setup-python@v5
1818
with:
1919
python-version: ${{ matrix.python-version }}
2020
- name: Install dependencies
2121
run: |
2222
python -m pip install --upgrade pip
2323
pip install . -r requirements/test_requirements.txt
24-
- name: Get Credential
25-
run: |
26-
mkdir -p ~/.local/share/neon
27-
echo $CONNECTOR_CONFIG > ~/.local/share/neon/credentials.json
28-
shell: bash
29-
env:
30-
CONNECTOR_CONFIG: ${{secrets.CONNECTOR_CONFIG}}
31-
- name: Run Utils Tests
24+
- name: Run Backward Compatibility Tests
3225
run: |
33-
pytest tests/test_utils.py --doctest-modules --junitxml=tests/utils-test-results.xml
34-
- name: Upload Utils test results
35-
uses: actions/upload-artifact@v2
26+
pytest tests/backward_compat_tests.py --doctest-modules --junitxml=tests/backward-compatibility-test-results.xml
27+
- name: Upload Backward Compatibility test results
28+
uses: actions/upload-artifact@v4
3629
with:
37-
name: utils-test-results
38-
path: tests/utils-test-results.xml
39-
- name: Run Connector Tests
40-
run: |
41-
pytest tests/test_connector.py --doctest-modules --junitxml=tests/connector-test-results.xml
42-
# env:
43-
# MQ_TESTING: 1
44-
- name: Upload Connector test results
45-
uses: actions/upload-artifact@v2
30+
name: backward-compatibility-test-results-${{ matrix.python-version }}
31+
path: tests/backward-compatibility-test-results.xml
32+
unit_tests:
33+
strategy:
34+
matrix:
35+
python-version: [ '3.8', '3.9', '3.10', '3.11', '3.12' ]
36+
timeout-minutes: 30
37+
runs-on: ubuntu-latest
38+
steps:
39+
- uses: actions/checkout@v4
40+
- name: Set up python ${{ matrix.python-version }}
41+
uses: actions/setup-python@v5
4642
with:
47-
name: connector-test-results
48-
path: tests/connector-test-results.xml
49-
- name: Run Backward Compatibility Tests
43+
python-version: ${{ matrix.python-version }}
44+
- name: Install apt dependencies
5045
run: |
51-
pytest tests/test_backward_compatibility.py --doctest-modules --junitxml=tests/backward-compatibility-test-results.xml
52-
- name: Upload Backward Compatibility test results
53-
uses: actions/upload-artifact@v2
46+
sudo apt update
47+
sudo apt install -y rabbitmq-server
48+
49+
- name: Install dependencies
50+
run: |
51+
python -m pip install --upgrade pip
52+
pip install . -r requirements/test_requirements.txt
53+
54+
- name: Run Unit Tests
55+
run: |
56+
pytest tests --doctest-modules --junitxml=tests/test-results.xml
57+
- name: Upload test results
58+
uses: actions/upload-artifact@v4
5459
with:
55-
name: backward-compatibility-test-results
56-
path: tests/backward-compatibility-test-results.xml
60+
name: test-results-${{ matrix.python-version }}
61+
path: tests/test-results.xml

‎CHANGELOG.md

Lines changed: 143 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -1,52 +1,176 @@
11
# Changelog
22

3-
## [0.7.1](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1) (2023-12-11)
3+
## [0.7.2a21](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a21) (2025-01-27)
44

5-
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a5...0.7.1)
5+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a20...0.7.2a21)
66

7-
**Closed issues:**
7+
**Merged pull requests:**
8+
9+
- Update to ensure `message_id` is not None [\#121](https://github.com/NeonGeckoCom/neon_mq_connector/pull/121) ([NeonDaniel](https://github.com/NeonDaniel))
10+
11+
## [0.7.2a20](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a20) (2025-01-24)
12+
13+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a19...0.7.2a20)
14+
15+
**Merged pull requests:**
16+
17+
- Update param name to avoid conflict with `threading.Thread` [\#120](https://github.com/NeonGeckoCom/neon_mq_connector/pull/120) ([NeonDaniel](https://github.com/NeonDaniel))
18+
19+
## [0.7.2a19](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a19) (2025-01-24)
20+
21+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a18...0.7.2a19)
22+
23+
**Merged pull requests:**
24+
25+
- Handle RMQ checks with default vhost [\#119](https://github.com/NeonGeckoCom/neon_mq_connector/pull/119) ([NeonDaniel](https://github.com/NeonDaniel))
26+
27+
## [0.7.2a18](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a18) (2025-01-23)
28+
29+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a17...0.7.2a18)
30+
31+
**Merged pull requests:**
832

9-
- remove hard-coded configuration of log level [\#87](https://github.com/NeonGeckoCom/neon_mq_connector/issues/87)
33+
- Improved Startup Connectivity Checks [\#117](https://github.com/NeonGeckoCom/neon_mq_connector/pull/117) ([NeonDaniel](https://github.com/NeonDaniel))
1034

11-
## [0.7.1a5](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a5) (2023-12-09)
35+
## [0.7.2a17](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a17) (2025-01-23)
1236

13-
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a4...0.7.1a5)
37+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a16...0.7.2a17)
1438

1539
**Merged pull requests:**
1640

17-
- Reduce message emit log to `DEBUG` [\#93](https://github.com/NeonGeckoCom/neon_mq_connector/pull/93) ([NeonDaniel](https://github.com/NeonDaniel))
41+
- Update copyright notices to 2025 [\#118](https://github.com/NeonGeckoCom/neon_mq_connector/pull/118) ([NeonDaniel](https://github.com/NeonDaniel))
1842

19-
## [0.7.1a4](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a4) (2023-08-11)
43+
## [0.7.2a16](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a16) (2025-01-23)
2044

21-
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a3...0.7.1a4)
45+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a15...0.7.2a16)
2246

2347
**Merged pull requests:**
2448

25-
- Update `message_id` handling for response routing [\#92](https://github.com/NeonGeckoCom/neon_mq_connector/pull/92) ([NeonDaniel](https://github.com/NeonDaniel))
49+
- Support Select Connections in `emit_mq_message` [\#115](https://github.com/NeonGeckoCom/neon_mq_connector/pull/115) ([NeonDaniel](https://github.com/NeonDaniel))
2650

27-
## [0.7.1a3](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a3) (2023-07-28)
51+
## [0.7.2a15](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a15) (2025-01-23)
2852

29-
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a2...0.7.1a3)
53+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a14...0.7.2a15)
3054

3155
**Merged pull requests:**
3256

33-
- Update message\_id handling for iris compat [\#91](https://github.com/NeonGeckoCom/neon_mq_connector/pull/91) ([NeonDaniel](https://github.com/NeonDaniel))
57+
- Update default async consumer behavior and configuration [\#113](https://github.com/NeonGeckoCom/neon_mq_connector/pull/113) ([NeonDaniel](https://github.com/NeonDaniel))
3458

35-
## [0.7.1a2](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a2) (2023-07-27)
59+
## [0.7.2a14](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a14) (2025-01-22)
3660

37-
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1a1...0.7.1a2)
61+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a13...0.7.2a14)
3862

3963
**Merged pull requests:**
4064

41-
- Update logging and response routing [\#89](https://github.com/NeonGeckoCom/neon_mq_connector/pull/89) ([NeonDaniel](https://github.com/NeonDaniel))
65+
- 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))
4266

43-
## [0.7.1a1](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.1a1) (2023-07-26)
67+
## [0.7.2a13](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a13) (2025-01-17)
4468

45-
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.0...0.7.1a1)
69+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a12...0.7.2a13)
4670

4771
**Merged pull requests:**
4872

49-
- 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))
73+
- Update logging in select consumer close [\#112](https://github.com/NeonGeckoCom/neon_mq_connector/pull/112) ([NeonDaniel](https://github.com/NeonDaniel))
74+
75+
## [0.7.2a12](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a12) (2025-01-16)
76+
77+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a11...0.7.2a12)
78+
79+
**Merged pull requests:**
80+
81+
- Resolve observed connection errors [\#111](https://github.com/NeonGeckoCom/neon_mq_connector/pull/111) ([NeonDaniel](https://github.com/NeonDaniel))
82+
83+
## [0.7.2a11](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a11) (2025-01-14)
84+
85+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a10...0.7.2a11)
86+
87+
**Merged pull requests:**
88+
89+
- Define `shutdown` method for NeonMQHandler with unit test coverage [\#110](https://github.com/NeonGeckoCom/neon_mq_connector/pull/110) ([NeonDaniel](https://github.com/NeonDaniel))
90+
91+
## [0.7.2a10](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a10) (2025-01-13)
92+
93+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a9...0.7.2a10)
94+
95+
**Merged pull requests:**
96+
97+
- Fix ` reconnection` with unit test coverage [\#109](https://github.com/NeonGeckoCom/neon_mq_connector/pull/109) ([NeonDaniel](https://github.com/NeonDaniel))
98+
99+
## [0.7.2a9](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a9) (2025-01-02)
100+
101+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a8...0.7.2a9)
102+
103+
**Merged pull requests:**
104+
105+
- Improve connection close and error handling [\#107](https://github.com/NeonGeckoCom/neon_mq_connector/pull/107) ([NeonDaniel](https://github.com/NeonDaniel))
106+
107+
## [0.7.2a8](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a8) (2024-12-11)
108+
109+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a7...0.7.2a8)
110+
111+
**Merged pull requests:**
112+
113+
- 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))
114+
115+
## [0.7.2a7](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a7) (2024-12-05)
116+
117+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a6...0.7.2a7)
118+
119+
**Merged pull requests:**
120+
121+
- \[Bug Fix\] Fixing issue with reopenning connection on consumers [\#103](https://github.com/NeonGeckoCom/neon_mq_connector/pull/103) ([NeonKirill](https://github.com/NeonKirill))
122+
123+
## [0.7.2a6](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a6) (2024-12-05)
124+
125+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a5...0.7.2a6)
126+
127+
**Merged pull requests:**
128+
129+
- 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))
130+
131+
## [0.7.2a5](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a5) (2024-12-03)
132+
133+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a4...0.7.2a5)
134+
135+
**Merged pull requests:**
136+
137+
- \[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))
138+
139+
## [0.7.2a4](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a4) (2024-11-21)
140+
141+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a3...0.7.2a4)
142+
143+
**Implemented enhancements:**
144+
145+
- \[FEAT\] Update tests to run without org secrets [\#97](https://github.com/NeonGeckoCom/neon_mq_connector/issues/97)
146+
147+
**Merged pull requests:**
148+
149+
- \[FEAT\] Async-based Consumers Support [\#99](https://github.com/NeonGeckoCom/neon_mq_connector/pull/99) ([NeonKirill](https://github.com/NeonKirill))
150+
151+
## [0.7.2a3](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a3) (2024-09-12)
152+
153+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a2...0.7.2a3)
154+
155+
**Merged pull requests:**
156+
157+
- Update OVOS dependencies [\#98](https://github.com/NeonGeckoCom/neon_mq_connector/pull/98) ([NeonDaniel](https://github.com/NeonDaniel))
158+
159+
## [0.7.2a2](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a2) (2024-04-25)
160+
161+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.2a1...0.7.2a2)
162+
163+
**Merged pull requests:**
164+
165+
- feat: allow ovos-utils 0.1.0 [\#96](https://github.com/NeonGeckoCom/neon_mq_connector/pull/96) ([mikejgray](https://github.com/mikejgray))
166+
167+
## [0.7.2a1](https://github.com/NeonGeckoCom/neon_mq_connector/tree/0.7.2a1) (2024-03-30)
168+
169+
[Full Changelog](https://github.com/NeonGeckoCom/neon_mq_connector/compare/0.7.1...0.7.2a1)
170+
171+
**Fixed bugs:**
172+
173+
- Fixing Issues with Consumers termination [\#95](https://github.com/NeonGeckoCom/neon_mq_connector/pull/95) ([NeonKirill](https://github.com/NeonKirill))
50174

51175

52176

‎LICENSE.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
# NEON AI (TM) SOFTWARE, Software Development Kit & Application Development System
22
# All trademark and other rights reserved by their respective owners
3-
# Copyright 2008-2021 Neongecko.com Inc.
3+
# Copyright 2008-2025 Neongecko.com Inc.
44
# BSD-3 License
55

66
Redistribution and use in source and binary forms, with or without modification, are permitted provided that the

‎README.md

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,3 +66,27 @@ A response may be sent via:
6666
)
6767
```
6868
Where `<queue>` is the queue to which the response will be published, and `data` is a `bytes` response (generally a `base64`-encoded `dict`).
69+
70+
### Asynchronous Consumers
71+
By default, async-based consumers handling based on `pika.SelectConnection` will
72+
be used
73+
74+
#### Override use of async consumers
75+
76+
There are a few methods to disable use of async consumers/subscribers.
77+
78+
1. To disable async consumers for a particular class/object,
79+
set the class-attribute `async_consumers_enabled` to `False`:
80+
81+
```python
82+
from neon_mq_connector import MQConnector
83+
84+
class MQConnectorChild(MQConnector):
85+
async_consumers_enabled = False
86+
```
87+
2. To disable the use of async consumers at runtime, set the `MQ_ASYNC_CONSUMERS`
88+
envvar to `False`
89+
90+
```shell
91+
export MQ_ASYNC_CONSUMERS=false
92+
```

‎neon_mq_connector/__init__.py

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

‎neon_mq_connector/config.py

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

0 commit comments

Comments
 (0)