return rpcError.get();
}
- public RoutedBindingRTClient(RpcConsumerRegistry registry, int inSize, List<InstanceIdentifier<?>> routeIid) {
+ public RoutedBindingRTClient(final RpcConsumerRegistry registry, final int inSize, final List<InstanceIdentifier<?>> routeIid) {
if (registry != null) {
this.service = registry.getRpcService(RpcbenchPayloadService.class);
} else {
}
- public void runTest(int iterations) {
+ public void runTest(final int iterations) {
int rpcOk = 0;
int rpcError = 0;
rpcError++;
}
}
- } catch (InterruptedException e) {
- rpcError++;
- LOG.error("Execution failed: ", e);
- } catch (ExecutionException e) {
+ } catch (InterruptedException | ExecutionException e) {
rpcError++;
LOG.error("Execution failed: ", e);
}