support for custom serializer

src/main/java/com/arhs/spring/cache/mongo/MongoCache.java

@@ -24,9 +24,10 @@
 package com.arhs.spring.cache.mongo;
 
 import com.arhs.spring.cache.mongo.domain.CacheDocument;
+import com.arhs.spring.cache.mongo.serializer.JavaSerializer;
+import com.arhs.spring.cache.mongo.serializer.Serializer;
 import com.mongodb.DBCollection;
 import com.mongodb.DBObject;
-import org.mockito.internal.matchers.Null;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.cache.Cache;
@@ -68,6 +69,7 @@ public class MongoCache implements Cache {
     private final long ttl;
 
     private final Object lock = new Object();
+    private Serializer serializer;
 
     /**
      * Constructor.
@@ -89,7 +91,20 @@ public MongoCache(String cacheName, String collectionName, MongoTemplate mongoTe
      * @param ttl            a time-to-live (in seconds).
      */
     public MongoCache(String cacheName, String collectionName, MongoTemplate mongoTemplate, long ttl) {
-        this(cacheName, collectionName, mongoTemplate, ttl, false);
+        this(cacheName, collectionName, mongoTemplate, ttl, false, new JavaSerializer());
+    }
+
+    /**
+     * Constructor.
+     *
+     * @param cacheName	     a cache name.
+     * @param collectionName a collection name.
+     * @param mongoTemplate  a {@link MongoTemplate} instance.
+     * @param ttl			 a time-to-live (in seconds).
+     * @param serializer     a serializer.
+     */
+    public MongoCache(String cacheName, String collectionName, MongoTemplate mongoTemplate, long ttl, Serializer serializer) {
+        this(cacheName, collectionName, mongoTemplate, ttl, false, serializer);
     }
 
     /**
@@ -102,6 +117,20 @@ public MongoCache(String cacheName, String collectionName, MongoTemplate mongoTe
      * @param flushOnBoot    a value that indicates if the collection must be always flush.
      */
     public MongoCache(String cacheName, String collectionName, MongoTemplate mongoTemplate, long ttl, boolean flushOnBoot) {
+        this(cacheName, collectionName, mongoTemplate, ttl, flushOnBoot, new JavaSerializer());
+    }
+
+    /**
+     * Constructor.
+     *
+     * @param cacheName      a cache name.
+     * @param collectionName a collection name.
+     * @param mongoTemplate  a {@link MongoTemplate} instance.
+     * @param ttl            a time-to-live (in seconds).
+     * @param flushOnBoot    a value that indicates if the collection must be always flush.
+     * @param serializer     a serializer.
+     */
+    public MongoCache(String cacheName, String collectionName, MongoTemplate mongoTemplate, long ttl, boolean flushOnBoot, Serializer serializer) {
         Assert.hasText(cacheName, "'cacheName' must be not null and not empty.");
         Assert.notNull(collectionName, "'collectionName' must be not null.");
         Assert.notNull(collectionName, "'mongoTemplate' must be not null.");
@@ -111,6 +140,7 @@ public MongoCache(String cacheName, String collectionName, MongoTemplate mongoTe
         this.mongoTemplate = mongoTemplate;
         this.cacheName = cacheName;
         this.ttl = ttl;
+        this.serializer = serializer == null ? new JavaSerializer() : serializer;
 
         initialize();
     }
@@ -269,10 +299,7 @@ public ValueWrapper putIfAbsent(Object key, Object value) {
     private Object deserialize(String value) throws IOException, ClassNotFoundException {
         final Base64.Decoder decoder = Base64.getDecoder();
         final byte[] data = decoder.decode(value);
-        try (final ByteArrayInputStream buffer = new ByteArrayInputStream(data);
-                final ObjectInputStream output = new ObjectInputStream(buffer)) {
-            return output.readObject();
-        }
+        return serializer.deserialize(data);
     }
 
     private Object getFromCache(Object key) {
@@ -307,16 +334,8 @@ private void initialize() {
     }
 
     private String serialize(Object value) throws IOException {
-        try (final ByteArrayOutputStream buffer = new ByteArrayOutputStream();
-                final ObjectOutputStream output = new ObjectOutputStream(buffer)) {
-
-            output.writeObject(value);
-
-            final byte[] data = buffer.toByteArray();
-
-            final Base64.Encoder encoder = Base64.getEncoder();
-            return encoder.encodeToString(data);
-        }
+        final Base64.Encoder encoder = Base64.getEncoder();
+        return encoder.encodeToString(serializer.serialize(value));
     }
 
     private Index createExpireIndex() {

src/main/java/com/arhs/spring/cache/mongo/MongoCacheBuilder.java

@@ -23,6 +23,7 @@
  */
 package com.arhs.spring.cache.mongo;
 
+import com.arhs.spring.cache.mongo.serializer.Serializer;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.util.Assert;
 
@@ -42,6 +43,7 @@ public class MongoCacheBuilder {
     private String collectionName;
     private MongoTemplate mongoTemplate;
     private long ttl;
+    private Serializer serializer;
 
     /**
      * Constructor.
@@ -79,7 +81,7 @@ public static MongoCacheBuilder newInstance(String collectionName, MongoTemplate
      * @return a {@link MongoCache} instance.
      */
     public MongoCache build() {
-        return new MongoCache(cacheName, collectionName, mongoTemplate, ttl, flushOnBoot);
+        return new MongoCache(cacheName, collectionName, mongoTemplate, ttl, flushOnBoot, serializer);
     }
 
     /**
@@ -104,4 +106,9 @@ public MongoCacheBuilder withTTL(long ttl) {
         return this;
     }
 
+    public MongoCacheBuilder withSerializer(Serializer serializer) {
+        this.serializer = serializer;
+        return this;
+    }
+
 }

src/main/java/com/arhs/spring/cache/mongo/serializer/JavaSerializer.java

@@ -0,0 +1,24 @@
+package com.arhs.spring.cache.mongo.serializer;
+
+import java.io.*;
+
+public class JavaSerializer implements Serializer {
+	@Override
+	public byte[] serialize(Object obj) throws IOException {
+		try (final ByteArrayOutputStream buffer = new ByteArrayOutputStream();
+			 final ObjectOutputStream output = new ObjectOutputStream(buffer)) {
+
+			output.writeObject(obj);
+
+			return buffer.toByteArray();
+		}
+	}
+
+	@Override
+	public Object deserialize(byte[] bytes) throws IOException, ClassNotFoundException {
+		try (final ByteArrayInputStream buffer = new ByteArrayInputStream(bytes);
+			 final ObjectInputStream output = new ObjectInputStream(buffer)) {
+			return output.readObject();
+		}
+	}
+}

src/main/java/com/arhs/spring/cache/mongo/serializer/Serializer.java

@@ -0,0 +1,14 @@
+package com.arhs.spring.cache.mongo.serializer;
+
+import java.io.IOException;
+
+/**
+ * Created by dan on 3/1/17.
+ */
+public interface Serializer {
+
+	public byte[] serialize(Object obj) throws IOException;
+
+	public Object deserialize(byte[] bytes) throws IOException, ClassNotFoundException;
+
+}