diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py
index 0511bd53..13dc073e 100644
--- a/kombu/transport/redis.py
+++ b/kombu/transport/redis.py
@@ -570,9 +570,9 @@ class Channel(virtual.Channel):
                     try:
                         message = loads(bytes_to_str(payload['data']))
                     except (TypeError, ValueError):
-                        message = None
                         warn('Cannot process event on channel %r: %r',
                              channel, payload, exc_info=1)
+                        raise Empty()
                     return message, self._fanout_to_queue[channel]
         raise Empty()