Skip to content

Fix amqp #51

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 17 commits into
base: main
Choose a base branch
from
Open

Fix amqp #51

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
83de132
Add optional publish acknowledgement
abnegate Jul 4, 2025
de62aa7
Add enqueue retry loop
abnegate Jul 4, 2025
0be2649
Update amqplib
abnegate Jul 4, 2025
1185ef2
Update release
abnegate Jul 4, 2025
2199875
Fix workflow
abnegate Jul 4, 2025
02c5539
Default ack not required
abnegate Jul 4, 2025
e0d8b72
Update dev
abnegate Jul 4, 2025
71233d7
Add swoole ack test
abnegate Jul 4, 2025
63ed4d6
Single ack
abnegate Jul 4, 2025
5d08ed7
Declare exchange on wait ack
abnegate Jul 4, 2025
041d6c2
Lint
abnegate Jul 4, 2025
45448d7
Validations
abnegate Jul 4, 2025
d77d231
Remove redundant branch
abnegate Jul 4, 2025
25f9f57
Lint
abnegate Jul 4, 2025
afa3cfa
Channel per coroutine
abnegate Jul 4, 2025
c032f48
Abstract swoole with channel
abnegate Jul 4, 2025
2b85380
Early decl exchange
abnegate Jul 4, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions .github/workflows/tests.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,8 @@ jobs:
adapter:
[
AMQP,
AMQPAck,
AMQPSwoole,
Pool,
SwooleRedisCluster,
Swoole,
Expand Down
17 changes: 9 additions & 8 deletions composer.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,28 +19,29 @@
},
"scripts":{
"test": "phpunit",
"check": "vendor/bin/phpstan analyse",
"check": "vendor/bin/phpstan --memory-limit=2G analyse",
"format": "vendor/bin/pint",
"lint": "vendor/bin/pint --test"
},
"require": {
"php": ">=8.3",
"appwrite-labs/php-amqplib": "^0.1",
"appwrite-labs/php-amqplib": "0.1.*",
"utopia-php/cli": "0.15.*",
"utopia-php/framework": "0.33.*",
"utopia-php/telemetry": "0.1.*",
"utopia-php/pools": "0.8.*",
"utopia-php/fetch": "0.4.*"
},
"require-dev": {
"ext-redis": "*",
"swoole/ide-helper": "4.8.8",
"phpunit/phpunit": "^9.5.5",
"laravel/pint": "^0.2.3",
"workerman/workerman": "^4.0",
"phpstan/phpstan": "^1.8"
"swoole/ide-helper": "5.1.7",
"phpunit/phpunit": "9.*",
"laravel/pint": "1.*",
"workerman/workerman": "4.*",
"phpstan/phpstan": "1.*"
},
"suggest": {
"ext-redis": "Needed to support Redis.",
"ext-amqp": "Needed to support AMQP.",
"ext-swoole": "Needed to support Swoole.",
"workerman/workerman": "Needed to support Workerman."
},
Expand Down
Loading