From bb3807c6c94a5bf4c13e157c4e280b6fadd44486 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Thu, 8 Feb 2018 09:55:16 +0300
Subject: [PATCH] Fixed - Jackson 2.9 compatibility
---
.../java/org/redisson/client/codec/JsonJacksonMapCodec.java | 3 ++-
.../src/main/java/org/redisson/codec/JsonJacksonCodec.java | 3 ++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/redisson/src/main/java/org/redisson/client/codec/JsonJacksonMapCodec.java b/redisson/src/main/java/org/redisson/client/codec/JsonJacksonMapCodec.java
index 441559979..abbcd70a9 100644
--- a/redisson/src/main/java/org/redisson/client/codec/JsonJacksonMapCodec.java
+++ b/redisson/src/main/java/org/redisson/client/codec/JsonJacksonMapCodec.java
@@ -17,6 +17,7 @@ package org.redisson.client.codec;
import java.io.IOException;
import java.io.InputStream;
+import java.io.OutputStream;
import org.redisson.client.handler.State;
import org.redisson.client.protocol.Decoder;
@@ -52,7 +53,7 @@ public class JsonJacksonMapCodec extends JsonJacksonCodec {
ByteBuf out = ByteBufAllocator.DEFAULT.buffer();
try {
ByteBufOutputStream os = new ByteBufOutputStream(out);
- mapper.writeValue(os, in);
+ mapper.writeValue((OutputStream)os, in);
return os.buffer();
} catch (IOException e) {
out.release();
diff --git a/redisson/src/main/java/org/redisson/codec/JsonJacksonCodec.java b/redisson/src/main/java/org/redisson/codec/JsonJacksonCodec.java
index 4df9a9939..8b9820800 100755
--- a/redisson/src/main/java/org/redisson/codec/JsonJacksonCodec.java
+++ b/redisson/src/main/java/org/redisson/codec/JsonJacksonCodec.java
@@ -17,6 +17,7 @@ package org.redisson.codec;
import java.io.IOException;
import java.io.InputStream;
+import java.io.OutputStream;
import javax.xml.datatype.XMLGregorianCalendar;
@@ -72,7 +73,7 @@ public class JsonJacksonCodec implements Codec {
ByteBuf out = ByteBufAllocator.DEFAULT.buffer();
try {
ByteBufOutputStream os = new ByteBufOutputStream(out);
- mapObjectMapper.writeValue(os, in);
+ mapObjectMapper.writeValue((OutputStream)os, in);
return os.buffer();
} catch (IOException e) {
out.release();