This is an automated email from the ASF dual-hosted git repository.
iluo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new a5e3f54 Dubbo throws exception when use java serializer #4612 (#4613)
a5e3f54 is described below
commit a5e3f5460af0536549338a3be94d3a21710a73f4
Author: 祁晓波 <[email protected]>
AuthorDate: Mon Jul 22 19:12:25 2019 +0800
Dubbo throws exception when use java serializer #4612 (#4613)
---
.../src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboCodec.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboCodec.java
b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboCodec.java
index 3b8fe66..f913437 100644
---
a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboCodec.java
+++
b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboCodec.java
@@ -120,10 +120,11 @@ public class DubboCodec extends ExchangeCodec {
}
try {
Object data;
- ObjectInput in = CodecSupport.deserialize(channel.getUrl(),
is, proto);
if (req.isHeartbeat()) {
+ ObjectInput in =
CodecSupport.deserialize(channel.getUrl(), is, proto);
data = decodeHeartbeatData(channel, in);
} else if (req.isEvent()) {
+ ObjectInput in =
CodecSupport.deserialize(channel.getUrl(), is, proto);
data = decodeEventData(channel, in);
} else {
DecodeableRpcInvocation inv;