Skip to content

Commit c69b061

Browse files
authored
Fix: always acknowledge MQ message in message websocket (#425)
1 parent e398ff9 commit c69b061

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/aleph/web/controllers/messages.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -264,10 +264,12 @@ async def messages_ws(request: web.Request) -> web.WebSocketResponse:
264264
try:
265265
async with mq_queue.iterator() as queue_iter:
266266
async for mq_message in queue_iter:
267+
# Always acknowledge the message
268+
await mq_message.ack()
269+
267270
if ws.closed:
268271
break
269272

270-
await mq_message.ack()
271273
item_hash = aleph_json.loads(mq_message.body)["item_hash"]
272274
# A bastardized way to apply the filters on the message as well.
273275
# TODO: put the filter key/values in the RabbitMQ message?

0 commit comments

Comments
 (0)