feat: added delete method to redis message (fixed tests timeout)

Author: ilya-4real

tests/brokers/redis/test_consume.py

@@ -684,7 +684,7 @@ async def handler(msg: RedisStreamMessage):
                         asyncio.create_task(br.publish("hello", stream=queue)),
                         asyncio.create_task(event.wait()),
                     ),
-                    timeout=300,
+                    timeout=3,
                 )
 
                 m.mock.assert_called_once()
@@ -716,7 +716,7 @@ async def handler(msg: RedisStreamMessage):
                         asyncio.create_task(br.publish("hello", stream=queue)),
                         asyncio.create_task(event.wait()),
                     ),
-                    timeout=300,
+                    timeout=3,
                 )
 
                 m.mock.assert_called_once()