private RpcProviderRegistry providerRegistry;
@Override
- public void onSessionInitiated(ProviderContext session) {
+ public void onSessionInitiated(final ProviderContext session) {
LOG.debug("RpcbenchmarkProvider Session Initiated");
consumerRegistry = session.getSALService(RpcConsumerRegistry.class);
providerRegistry = session.getSALService(RpcProviderRegistry.class);
executor.shutdown();
try {
executor.awaitTermination(testTimeout, TimeUnit.MINUTES);
- } catch (InterruptedException e) {
+ } catch (final InterruptedException e) {
LOG.error("Out of time: test did not finish within the {} min deadline ", testTimeout);
}