INT-2029 added initial implementation of RedisMessageStore. Upgraded Jackson to version 1.8.3 which is used by spring-data-redis. Regenerated POM files

spring-integration-redis/src/main/java/org/springframework/integration/redis/store/RedisMessageStore.java

@@ -0,0 +1,80 @@
+/*
+ * Copyright 2007-2011 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 org.springframework.integration.redis.store;
+
+import java.util.UUID;
+
+import org.springframework.dao.DataAccessException;
+import org.springframework.data.redis.connection.RedisConnection;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.BoundValueOperations;
+import org.springframework.data.redis.core.RedisCallback;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.JacksonJsonRedisSerializer;
+import org.springframework.integration.Message;
+import org.springframework.integration.store.MessageStore;
+
+/**
+ * @author Oleg Zhurakousky
+ * @since 2.1
+ *
+ */
+public class RedisMessageStore implements MessageStore {
+
+	private final RedisTemplate<UUID, Message<?>> redisTemplate;
+	
+	public RedisMessageStore(RedisConnectionFactory connectionFactory){
+		this.redisTemplate = new RedisTemplate<UUID, Message<?>>();
+		this.redisTemplate.setConnectionFactory(connectionFactory);
+		this.redisTemplate.setKeySerializer(new JacksonJsonRedisSerializer<UUID>(UUID.class));	
+	}
+	
+	public Message<?> getMessage(final UUID id) {
+		boolean exists = redisTemplate.execute(new RedisCallback<Boolean>() {
+
+			public Boolean doInRedis(RedisConnection connection)
+					throws DataAccessException {
+				return connection.exists(id.toString().getBytes());
+			}
+		});
+		if (!exists){
+			return null;
+		}
+		else {
+			BoundValueOperations<UUID, Message<?>> ops = redisTemplate.boundValueOps(id);		
+			return ops.get();
+		}	
+	}
+
+	
+	public <T> Message<T> addMessage(Message<T> message) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	
+	public Message<?> removeMessage(UUID id) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	
+	public int getMessageCount() {
+		// TODO Auto-generated method stub
+		return 0;
+	}
+
+}

spring-integration-redis/src/test/java/org/springframework/integration/redis/store/RedisMessageStoreTests.java

@@ -0,0 +1,44 @@
+/*
+ * Copyright 2007-2011 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 org.springframework.integration.redis.store;
+
+import java.util.UUID;
+
+import org.junit.Ignore;
+import org.junit.Test;
+import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
+import org.springframework.integration.Message;
+
+import static org.junit.Assert.assertNull;
+
+/**
+ * @author Oleg Zhurakousky
+ *
+ */
+public class RedisMessageStoreTests {
+
+	@Test
+	@Ignore
+	public void testGetNonExistingMessage(){
+		
+		JedisConnectionFactory jcf = new JedisConnectionFactory();
+		jcf.setPort(6379);
+		jcf.afterPropertiesSet();
+		RedisMessageStore store = new RedisMessageStore(jcf);
+		Message<?> message = store.getMessage(UUID.randomUUID());
+		assertNull(message);
+	}
+}