ISSUE-283 Metadata type constructor-transmitted

Author: eutkin

cluster-codec-parent/cluster-codec-jackson/src/main/java/io/scalecube/cluster/codec/jackson/JacksonMetadataEncoder.java

@@ -16,25 +16,29 @@
  */
 public class JacksonMetadataEncoder implements MetadataEncoder, MetadataDecoder {
 
-  private static final TypeReference<Map<String, String>> TYPE =
+  private static final TypeReference<Map<String, String>> DEFAULT_TYPE =
       new TypeReference<Map<String, String>>() {};
 
   private final ObjectMapper delegate;
+  private final TypeReference<?> type;
 
   /**
    * Create instance with external {@link ObjectMapper}.
    *
    * @param delegate jackson object mapper
+   * @param type type of metadata
    */
-  public JacksonMetadataEncoder(ObjectMapper delegate) {
+  public JacksonMetadataEncoder(ObjectMapper delegate, TypeReference<?> type) {
     this.delegate = delegate;
+    this.type = type;
   }
 
   /**
    * Create instance with default {@link ObjectMapper}.
    */
   public JacksonMetadataEncoder() {
     this.delegate = DefaultObjectMapper.OBJECT_MAPPER;
+    this.type = DEFAULT_TYPE;
   }
 
   /**
@@ -49,7 +53,7 @@ public Object decode(ByteBuffer buffer) {
       if (buffer.remaining() == 0) {
         return Collections.emptyMap();
       }
-      return this.delegate.readValue(buffer.array(), TYPE);
+      return this.delegate.readValue(buffer.array(), this.type);
     } catch (Exception e) {
       throw Exceptions.propagate(e);
     }
@@ -64,7 +68,7 @@ public Object decode(ByteBuffer buffer) {
   @Override
   public ByteBuffer encode(Object metadata) {
     try {
-      return ByteBuffer.wrap(this.delegate.writeValueAsBytes(metadata));
+      return ByteBuffer.wrap(this.delegate.writerFor(this.type).writeValueAsBytes(metadata));
     } catch (Exception e) {
       throw Exceptions.propagate(e);
     }