diff --git a/src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java b/src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java
index f82bd69690..2c4fa43de2 100644
--- a/src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java
+++ b/src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java
@@ -826,7 +826,7 @@ public void onMessage(Message message, @Nullable byte[] pattern) {
 
 		private boolean isKeyExpirationMessage(Message message) {
 
-			if (message == null || message.getChannel() == null || message.getBody() == null) {
+			if (message == null) {
 				return false;
 			}