diff --git a/src/main/java/com/loafle/overflow/container/configuration/ContainerConfiguration.java b/src/main/java/com/loafle/overflow/container/configuration/ContainerConfiguration.java index 738756a..26f79e5 100644 --- a/src/main/java/com/loafle/overflow/container/configuration/ContainerConfiguration.java +++ b/src/main/java/com/loafle/overflow/container/configuration/ContainerConfiguration.java @@ -53,7 +53,7 @@ public class ContainerConfiguration { @Bean(Client.CHANNEL_HANDLERS) public List channelHandlers() { - List chs = Arrays.asList(new RPCClientHandler()); + List chs = Arrays.asList(this.rpcClientHandler()); if (null != this.extraChannelHandlers) { chs.addAll(this.extraChannelHandlers); } @@ -71,6 +71,11 @@ public class ContainerConfiguration { return new JSONRPCClientCodec(this.objectMapper); } + @Bean(Container.RPC_CLIENT_CODEC) + public RPCClientHandler rpcClientHandler() { + return new RPCClientHandler(); + } + @Bean({Container.RPC_INVOKER, Container.RPC_REGISTRY}) public RPCRegistry rpcRegistry() { return new RPCRegistry();