This commit is contained in:
crusader 2018-05-04 17:45:05 +09:00
parent bf5a8a7ec4
commit 40e22f3861

View File

@ -53,7 +53,7 @@ public class ContainerConfiguration {
@Bean(Client.CHANNEL_HANDLERS)
public List<ChannelHandler> channelHandlers() {
List<ChannelHandler> chs = Arrays.asList(new RPCClientHandler());
List<ChannelHandler> 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();