- public long getRpcOk() {
- return rpcOk.get();
- }
-
- public long getRpcError() {
- return rpcError.get();
- }
-
- public RoutedBindingRTClient(RpcConsumerRegistry registry, int inSize, List<InstanceIdentifier<?>> routeIid) {
- if (registry != null) {
- this.service = registry.getRpcService(RpcbenchPayloadService.class);
- } else {
- this.service = null;
- }
+ public RoutedBindingRTClient(final RpcService rpcService, final int inSize,
+ final List<InstanceIdentifier<?>> routeIid) {
+ routedRpcBench = rpcService.getRpc(RoutedRpcBench.class);