1616 */
1717public class JacksonMetadataEncoder implements MetadataEncoder , MetadataDecoder {
1818
19- private static final TypeReference <Map <String , String >> DEFAULT_TYPE =
19+ private static final TypeReference <Map <String , String >> TYPE =
2020 new TypeReference <Map <String , String >>() {};
2121
2222 private final ObjectMapper delegate ;
23- private final TypeReference <?> type ;
2423
2524 /**
2625 * Create instance with external {@link ObjectMapper}.
2726 *
2827 * @param delegate jackson object mapper
29- * @param type type of metadata
3028 */
31- public JacksonMetadataEncoder (ObjectMapper delegate , TypeReference <?> type ) {
29+ public JacksonMetadataEncoder (ObjectMapper delegate ) {
3230 this .delegate = delegate ;
33- this .type = type ;
3431 }
3532
3633 /**
3734 * Create instance with default {@link ObjectMapper}.
3835 */
3936 public JacksonMetadataEncoder () {
4037 this .delegate = DefaultObjectMapper .OBJECT_MAPPER ;
41- this .type = DEFAULT_TYPE ;
4238 }
4339
4440 /**
@@ -53,7 +49,7 @@ public Object decode(ByteBuffer buffer) {
5349 if (buffer .remaining () == 0 ) {
5450 return Collections .emptyMap ();
5551 }
56- return this .delegate .readValue (buffer .array (), this . type );
52+ return this .delegate .readValue (buffer .array (), TYPE );
5753 } catch (Exception e ) {
5854 throw Exceptions .propagate (e );
5955 }
@@ -68,7 +64,7 @@ public Object decode(ByteBuffer buffer) {
6864 @ Override
6965 public ByteBuffer encode (Object metadata ) {
7066 try {
71- return ByteBuffer .wrap (this .delegate .writerFor ( this . type ). writeValueAsBytes (metadata ));
67+ return ByteBuffer .wrap (this .delegate .writeValueAsBytes (metadata ));
7268 } catch (Exception e ) {
7369 throw Exceptions .propagate (e );
7470 }
0 commit comments