private TestingParallelAPSPImpl instance;
private String someParam;
- public TestingParallelAPSPModule(ModuleIdentifier identifier,
- DependencyResolver dependencyResolver,
- @Nullable AutoCloseable oldCloseable,
- @Nullable TestingParallelAPSPImpl oldInstance) {
+ public TestingParallelAPSPModule(final ModuleIdentifier identifier,
+ final DependencyResolver dependencyResolver,
+ @Nullable final AutoCloseable oldCloseable,
+ @Nullable final TestingParallelAPSPImpl oldInstance) {
this.identifier = identifier;
this.dependencyResolver = dependencyResolver;
this.oldCloseable = oldCloseable;
@RequireInterface(TestingThreadPoolServiceInterface.class)
@Override
- public void setThreadPool(ObjectName threadPoolName) {
+ public void setThreadPool(final ObjectName threadPoolName) {
this.threadPoolON = threadPoolName;
}
}
@Override
- public void setSomeParam(String someParam) {
+ public void setSomeParam(final String someParam) {
this.someParam = someParam;
}
dependencyResolver.resolveInstance(TestingThreadPoolIfc.class,
threadPoolON, threadPoolONJMXAttribute);
throw new RuntimeException("fail");
- } catch (IllegalStateException e) {
+ } catch (final IllegalStateException e) {
checkState("Commit was not triggered".equals(e.getMessage()),
e.getMessage());
}
int threadCount;
try {
threadCount = (Integer)dependencyResolver.getAttribute(threadPoolON, "ThreadCount");
- } catch (Exception e) {
+ } catch (final Exception e) {
throw new IllegalStateException(e);
}
checkState(threadCount > 0);
if (oldCloseable != null) {
try {
oldCloseable.close();
- } catch (Exception e) {
+ } catch (final Exception e) {
throw new RuntimeException(e);
}
}