Skip to content

Commit 39ee9fd

Browse files
committed
fix worker consume
1 parent fa810fd commit 39ee9fd

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

api/docker/supervisor/event.ini

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[program:event]
22
directory=/srv/app
3-
command=/bin/sh -c '/srv/app/bin/console rabbitmq:consumer -vvv --messages=100 event || (sleep 10s && false)'
3+
command=/bin/sh -c '/srv/app/bin/console messenger:consume async -vvv --limit=100 --time-limit=3600 --no-reset'
44
autorestart=true
55
stdout_logfile=/dev/stdout
66
stdout_logfile_maxbytes=0

api/src/Consumer/Handler/DeleteArchiveHandler.php

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,8 @@ public function __construct(private ArchiveManager $archiveManager,
1919
}
2020

2121
public function __invoke(DeleteArchive $message): void
22-
{
23-
$payload = $message->getPayload();
24-
$id = $payload['id'];
22+
{
23+
$id = $message->getId();
2524

2625
$archive = $this->em->find(Archive::class, $id);
2726
if (!$archive instanceof Archive) {

0 commit comments

Comments
 (0)