Added new synchronous integration flow for sending messages from kafka for subscriptions. If telegram api failed then exception is thrown and controller reply with error message 500. So kafka never acknowledge failed messages and should send them later again.
These changes doesn't affect work flow with input messages from chats. They still work in async flow mode.
Fixes #126
Type of change
[x] Bug fix (non-breaking change which fixes an issue)
How Has This Been Tested?
Please describe the tests that you ran to verify your changes. Provide instructions so we can reproduce. Please also list any relevant details for your test configuration
[x] Test sending messages from kafka. Should get 500 error in case of any exception in sync flow.
Test Configuration:
Firmware version: MacOS 14.3 (23D56)
Hardware: Apple M1 Pro
SDK: Eclipse Temurin JDK 21.0.2+13-LTS
Checklist:
[x] My code follows the style guidelines of this project
[x] I have performed a self-review of my code
[x] I have commented my code, particularly in hard-to-understand areas
[ ] I have made corresponding changes to the documentation
[x] My changes generate no new warnings
[ ] I have added tests that prove my fix is effective or that my feature works
[x] New and existing unit tests pass locally with my changes
[ ] Any dependent changes have been merged and published in downstream modules
[ ] I have updated project version if release is planned
Description
Added new synchronous integration flow for sending messages from kafka for subscriptions. If telegram api failed then exception is thrown and controller reply with error message 500. So kafka never acknowledge failed messages and should send them later again.
These changes doesn't affect work flow with input messages from chats. They still work in async flow mode.
Fixes #126
Type of change
How Has This Been Tested?
Please describe the tests that you ran to verify your changes. Provide instructions so we can reproduce. Please also list any relevant details for your test configuration
Test Configuration: Firmware version: MacOS 14.3 (23D56) Hardware: Apple M1 Pro SDK: Eclipse Temurin JDK 21.0.2+13-LTS
Checklist: