mindol1004/spring-boot-rest
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Clean up Spring Data Redis pub/sub example

Browse Source
This commit is contained in:
David Morley
2016-03-17 06:09:47 -05:00
parent 6f2ee52550
commit 7c030c6965
12 changed files with 24 additions and 83 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-data-redis/src/main/java/org/baeldung/spring/data/redis/config/RedisConfig.java → spring-data-redis/src/main/java/com/baeldung/spring/data/redis/config/RedisConfig.java
View File

@@ -1,8 +1,8 @@
package org.baeldung.spring.data.redis.config;
package com.baeldung.spring.data.redis.config;
import org.baeldung.spring.data.redis.queue.RedisMessageSubscriber;
import org.baeldung.spring.data.redis.queue.RedisMessagePublisher;
import org.baeldung.spring.data.redis.queue.MessagePublisher;
import com.baeldung.spring.data.redis.queue.MessagePublisher;
import com.baeldung.spring.data.redis.queue.RedisMessagePublisher;
import com.baeldung.spring.data.redis.queue.RedisMessageSubscriber;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
@@ -11,9 +11,10 @@ import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import org.springframework.data.redis.serializer.GenericToStringSerializer;
@Configuration
@ComponentScan("org.baeldung.spring.data.redis")
@ComponentScan("com.baeldung.spring.data.redis")
public class RedisConfig {
@Bean
@@ -25,6 +26,7 @@ public class RedisConfig {
public RedisTemplate<String, Object> redisTemplate() {
final RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
template.setConnectionFactory(jedisConnectionFactory());
template.setValueSerializer(new GenericToStringSerializer<Object>(Object.class));
return template;
}

2
spring-data-redis/src/main/java/org/baeldung/spring/data/redis/model/Student.java → spring-data-redis/src/main/java/com/baeldung/spring/data/redis/model/Student.java
View File

@@ -1,4 +1,4 @@
package org.baeldung.spring.data.redis.model;
package com.baeldung.spring.data.redis.model;
import java.io.Serializable;

2
spring-data-redis/src/main/java/org/baeldung/spring/data/redis/queue/MessagePublisher.java → spring-data-redis/src/main/java/com/baeldung/spring/data/redis/queue/MessagePublisher.java
View File

@@ -1,4 +1,4 @@
package org.baeldung.spring.data.redis.queue;
package com.baeldung.spring.data.redis.queue;
public interface MessagePublisher {

2
spring-data-redis/src/main/java/org/baeldung/spring/data/redis/queue/RedisMessagePublisher.java → spring-data-redis/src/main/java/com/baeldung/spring/data/redis/queue/RedisMessagePublisher.java
View File

@@ -1,4 +1,4 @@
package org.baeldung.spring.data.redis.queue;
package com.baeldung.spring.data.redis.queue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;

4
spring-data-redis/src/main/java/org/baeldung/spring/data/redis/queue/RedisMessageSubscriber.java → spring-data-redis/src/main/java/com/baeldung/spring/data/redis/queue/RedisMessageSubscriber.java
View File

@@ -1,4 +1,4 @@
package org.baeldung.spring.data.redis.queue;
package com.baeldung.spring.data.redis.queue;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
@@ -14,6 +14,6 @@ public class RedisMessageSubscriber implements MessageListener {
public void onMessage(final Message message, final byte[] pattern) {
messageList.add(message.toString());
System.out.println("Message received: " + message.toString());
System.out.println("Message received: " + new String(message.getBody()));
}
}

4
spring-data-redis/src/main/java/org/baeldung/spring/data/redis/repo/StudentRepository.java → spring-data-redis/src/main/java/com/baeldung/spring/data/redis/repo/StudentRepository.java
View File

@@ -1,6 +1,6 @@
package org.baeldung.spring.data.redis.repo;
package com.baeldung.spring.data.redis.repo;
import org.baeldung.spring.data.redis.model.Student;
import com.baeldung.spring.data.redis.model.Student;
import java.util.Map;

4
spring-data-redis/src/main/java/org/baeldung/spring/data/redis/repo/StudentRepositoryImpl.java → spring-data-redis/src/main/java/com/baeldung/spring/data/redis/repo/StudentRepositoryImpl.java
View File

@@ -1,6 +1,6 @@
package org.baeldung.spring.data.redis.repo;
package com.baeldung.spring.data.redis.repo;
import org.baeldung.spring.data.redis.model.Student;
import com.baeldung.spring.data.redis.model.Student;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;

8
spring-data-redis/src/test/java/org/baeldung/spring/data/redis/RedisMessageListenerTest.java → spring-data-redis/src/test/java/com/baeldung/spring/data/redis/RedisMessageListenerTest.java
View File

@@ -1,8 +1,8 @@
package org.baeldung.spring.data.redis;
package com.baeldung.spring.data.redis;
import org.baeldung.spring.data.redis.config.RedisConfig;
import org.baeldung.spring.data.redis.queue.RedisMessageSubscriber;
import org.baeldung.spring.data.redis.queue.RedisMessagePublisher;
import com.baeldung.spring.data.redis.config.RedisConfig;
import com.baeldung.spring.data.redis.queue.RedisMessageSubscriber;
import com.baeldung.spring.data.redis.queue.RedisMessagePublisher;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;

7
spring-data-redis/src/test/java/org/baeldung/spring/data/redis/repo/StudentRepositoryTest.java → spring-data-redis/src/test/java/com/baeldung/spring/data/redis/repo/StudentRepositoryTest.java
View File

@@ -1,8 +1,7 @@
package org.baeldung.spring.data.redis.repo;
package com.baeldung.spring.data.redis.repo;
import org.baeldung.spring.data.redis.config.RedisConfig;
import org.baeldung.spring.data.redis.model.Student;
import org.junit.Before;
import com.baeldung.spring.data.redis.config.RedisConfig;
import com.baeldung.spring.data.redis.model.Student;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;