Я пытаюсь использовать очередь сообщений Redis. Я должен разобраться со сценарием, что если в любой момент времени происходит сбой потребителя сообщений, то сообщения, которые уже получены и находятся в процессе, не должны быть потеряны, т. Е. Эти сообщения не должны быть исключены из очереди, пока потребитель не уведомит об обработке сообщения. выполнен. Я хотел функциональность, похожую на Peek-Lock, предоставляемую сервисной шиной Azure. Есть ли такой механизм блокировки для очереди redis, реализованный в golang.