Polishing.

Author: mp911de

redis/listener/src/main/java/example/springdata/redis/listener/Person.java

@@ -18,8 +18,8 @@
 	<modules>
 		<module>cluster</module>
 		<module>example</module>
-		<module>listener</module>
 		<module>pubsub</module>
+		<module>pubsub-listener</module>
 		<module>reactive</module>
 		<module>repositories</module>
 		<module>sentinel</module>

redis/pom.xml

@@ -10,9 +10,11 @@
 		<relativePath>../pom.xml</relativePath>
 	</parent>
 
-	<artifactId>spring-data-redis-listener</artifactId>
-	<name>Spring Data Redis - Annotated Listener</name>
-	<description>Sample project for Spring Data Redis @RedisListener annotation-driven Pub/Sub</description>
+	<artifactId>spring-data-redis-pubsub-listener</artifactId>
+	<name>Spring Data Redis - Annotated Pub/Sub Listener</name>
+	<description>Sample project for annotation-driven Spring Data Redis Pub/Sub
+		@RedisListener
+	</description>
 
 	<dependencies>
 

redis/listener/README.md redis/pubsub-listener/README.mdredis/listener/README.md renamed to redis/pubsub-listener/README.md

@@ -1,11 +1,11 @@
 /*
- * Copyright 2026-present the original author or authors.
+ * Copyright 2026 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
- *      https://www.apache.org/licenses/LICENSE-2.0
+ *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,

redis/listener/pom.xml redis/pubsub-listener/pom.xmlredis/listener/pom.xml renamed to redis/pubsub-listener/pom.xml

@@ -0,0 +1,25 @@
+/*
+ * Copyright 2026 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.redis.listener;
+
+/**
+ * Example domain type for JSON payloads in Redis Pub/Sub messages.
+ *
+ * @author Christoph Strobl
+ */
+public record Person(String firstname, String lastname) {
+
+}

…/springdata/redis/listener/Messages.java …/springdata/redis/listener/Messages.javaredis/listener/src/main/java/example/springdata/redis/listener/Messages.java renamed to redis/pubsub-listener/src/main/java/example/springdata/redis/listener/Messages.java redis/listener/src/main/java/example/springdata/redis/listener/Messages.java renamed to redis/pubsub-listener/src/main/java/example/springdata/redis/listener/Messages.java

@@ -1,11 +1,11 @@
 /*
- * Copyright 2026-present the original author or authors.
+ * Copyright 2026 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
- *      https://www.apache.org/licenses/LICENSE-2.0
+ *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -62,7 +62,8 @@ static class Listeners {
 		@RedisListener(topic = "string-channel")
 		public void processStringMessage(@Payload String data, MessageHeaders headers) {
 
-			System.out.printf("received message [%s] from [%s] at [%s].%n", data, headers.get("channel"), headers.getTimestamp());
+			System.out.printf("received message [%s] from [%s] at [%s].%n", data, headers.get("channel"),
+					headers.getTimestamp());
 			messages.capture(data);
 		}
 
@@ -77,17 +78,14 @@ public void processPersonMessage(Person person) {
 		}
 	}
 
-
 	@Bean
 	Messages messages() {
 		return new Messages();
 	}
 
 	/**
-	 * Provide required
-	 * {@link RedisMessageListenerContainer} for annotation-driven endpoints
-	 * {@link Listeners#processStringMessage(String, MessageHeaders)}} &
-	 * {@link Listeners#processPersonMessage(Person)}.
+	 * Provide required {@link RedisMessageListenerContainer} for annotation-driven endpoints
+	 * {@link Listeners#processStringMessage(String, MessageHeaders)}} & {@link Listeners#processPersonMessage(Person)}.
 	 *
 	 * @param connectionFactory must not be {@literal null}.
 	 * @return new instance of {@link RedisListenerApplication}.

redis/pubsub-listener/src/main/java/example/springdata/redis/listener/Person.java

@@ -1,11 +1,11 @@
 /*
- * Copyright 2026-present the original author or authors.
+ * Copyright 2026 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
- *      https://www.apache.org/licenses/LICENSE-2.0
+ *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -15,11 +15,12 @@
  */
 package example.springdata.redis.listener;
 
-import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.*;
 
 import java.util.concurrent.TimeUnit;
 
 import org.junit.jupiter.api.Test;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.annotation.Import;
@@ -39,8 +40,8 @@ class AnnotatedRedisListenerIntegrationTests {
 	@Autowired Messages messages;
 
 	/**
-	 * Publish a raw String message to the {@literal string-channel} channel and verify that the message
-	 * is received by the {@link RedisListenerApplication.Listeners#processStringMessage(String, MessageHeaders) string listener}.
+	 * Publish a raw String message to the {@literal string-channel} channel and verify that the message is received by
+	 * the {@link RedisListenerApplication.Listeners#processStringMessage(String, MessageHeaders) string listener}.
 	 */
 	@Test
 	void shouldReceiveStringMessage() throws Exception {
@@ -52,8 +53,8 @@ void shouldReceiveStringMessage() throws Exception {
 	}
 
 	/**
-	 * Publish a JSON String message to the {@literal person-channel} channel and verify that the payload is converted
-	 * and processed by the {@link RedisListenerApplication.Listeners#processPersonMessage(Person) person listener}.
+	 * Publish a JSON String message to the {@literal person-channel} channel and verify that the payload is converted and
+	 * processed by the {@link RedisListenerApplication.Listeners#processPersonMessage(Person) person listener}.
 	 */
 	@Test
 	void shouldReceiveJsonPersonMessage() throws Exception {
@@ -63,7 +64,7 @@ void shouldReceiveJsonPersonMessage() throws Exception {
 
 		Person received = messages.capturedPojos().poll(5, TimeUnit.SECONDS);
 		assertThat(received).isNotNull();
-		assertThat(received.getFirstname()).isEqualTo("Homer");
-		assertThat(received.getLastname()).isEqualTo("Simpson");
+		assertThat(received.firstname()).isEqualTo("Homer");
+		assertThat(received.lastname()).isEqualTo("Simpson");
 	}
 }

…s/listener/RedisListenerApplication.java …s/listener/RedisListenerApplication.javaredis/listener/src/main/java/example/springdata/redis/listener/RedisListenerApplication.java renamed to redis/pubsub-listener/src/main/java/example/springdata/redis/listener/RedisListenerApplication.java redis/listener/src/main/java/example/springdata/redis/listener/RedisListenerApplication.java renamed to redis/pubsub-listener/src/main/java/example/springdata/redis/listener/RedisListenerApplication.java

@@ -1,11 +1,11 @@
 /*
- * Copyright 2026-present the original author or authors.
+ * Copyright 2026 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
- *      https://www.apache.org/licenses/LICENSE-2.0
+ *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -15,12 +15,14 @@
  */
 package example.springdata.redis.listener;
 
-import com.redis.testcontainers.RedisContainer;
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.springframework.context.annotation.Bean;
+
 import org.testcontainers.utility.DockerImageName;
 
+import com.redis.testcontainers.RedisContainer;
+
 /**
  * Test configuration providing a Redis instance via Testcontainers.
  *