rpcbenchmark: final parameters

[controller.git] / benchmark / rpcbenchmark / src / main / java / rpcbenchmark / impl / GlobalBindingRTCClient.java

diff --git a/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/GlobalBindingRTCClient.java b/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/GlobalBindingRTCClient.java
index ea426ba990ff9c4fc0ad70a002f743e51bd66dbe..f03c064b03aee53f597dcba90d80d8f1d454150c 100644 (file)
--- a/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/GlobalBindingRTCClient.java
+++ b/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/GlobalBindingRTCClient.java
@@ -41,7 +41,7 @@ public class GlobalBindingRTCClient implements RTCClient {
         return rpcError.get();
     }
 
-    public GlobalBindingRTCClient(RpcConsumerRegistry registry, int inSize) {
+    public GlobalBindingRTCClient(final RpcConsumerRegistry registry, final int inSize) {
         if (registry != null) {
             this.service = registry.getRpcService(RpcbenchPayloadService.class);
         } else {
@@ -56,7 +56,7 @@ public class GlobalBindingRTCClient implements RTCClient {
         inVal = new GlobalRpcBenchInputBuilder().setPayload(listVals).build();
     }
 
-    public void runTest(int iterations) {
+    public void runTest(final int iterations) {
         int rpcOk = 0;
         int rpcError = 0;
 
@@ -74,10 +74,7 @@ public class GlobalBindingRTCClient implements RTCClient {
                         rpcError++;
                     }
                 }
-            } catch (InterruptedException e) {
-                rpcError++;
-                LOG.error("Execution failed: ", e);
-            } catch (ExecutionException e) {
+            } catch (InterruptedException | ExecutionException e) {
                 rpcError++;
                 LOG.error("Execution failed: ", e);
             }