Skip to content

Commit a2743e6

Browse files
committed
fix worker consume
1 parent a86b261 commit a2743e6

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
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: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,7 @@ public function __construct(private ArchiveManager $archiveManager,
2020

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

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

0 commit comments

Comments
 (0)