diff --git a/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java b/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java index 94266456c..3a8a4b3b4 100644 --- a/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java +++ b/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java @@ -105,6 +105,7 @@ import org.springframework.util.ErrorHandler; * * @author Mark Paluch * @author Christoph Strobl + * @author Christian Rest * @param Stream key and Stream field type. * @param Stream value type. * @since 2.2 @@ -723,7 +724,7 @@ public interface StreamMessageListenerContainer> exten * @return {@code this} {@link StreamMessageListenerContainerOptionsBuilder}. */ public StreamMessageListenerContainerOptionsBuilder> hashValueSerializer( - RedisSerializer serializer) { + RedisSerializer serializer) { Assert.notNull(serializer, "RedisSerializer must not be null");