fix: fix jraft response instance (alibaba#4644)

bobo365 · Jan 7, 2021 · 30ab49b · 30ab49b
1 parent 5f225d4
commit 30ab49b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/com/alibaba/nacos/core/distributed/raft/utils/JRaftUtils.java b/core/src/main/java/com/alibaba/nacos/core/distributed/raft/utils/JRaftUtils.java
@@ -71,8 +71,8 @@ public static RpcServer initRpcServer(JRaftServer server, PeerId peerId) {
         registry.registerResponseInstance(Log.class.getName(), Response.getDefaultInstance());
         registry.registerResponseInstance(GetRequest.class.getName(), Response.getDefaultInstance());
 
-        registry.registerResponseInstance(WriteRequest.class.getName(), WriteRequest.getDefaultInstance());
-        registry.registerResponseInstance(ReadRequest.class.getName(), ReadRequest.getDefaultInstance());
+        registry.registerResponseInstance(WriteRequest.class.getName(), Response.getDefaultInstance());
+        registry.registerResponseInstance(ReadRequest.class.getName(), Response.getDefaultInstance());
 
         final RpcServer rpcServer = raftRpcFactory.createRpcServer(peerId.getEndpoint());
         RaftRpcServerFactory.addRaftRequestProcessors(rpcServer, RaftExecutor.getRaftCoreExecutor(),