Skip to content
Snippets Groups Projects
Commit b500f87c authored by Christian Wulf's avatar Christian Wulf
Browse files

fixed PMD issues

parent 2fc7d23e
No related branches found
No related tags found
No related merge requests found
...@@ -64,6 +64,7 @@ ...@@ -64,6 +64,7 @@
<exclude name="AtLeastOneConstructor" /> <exclude name="AtLeastOneConstructor" />
<exclude name="AvoidUsingVolatile" /> <exclude name="AvoidUsingVolatile" />
<exclude name="CallSuperInConstructor" /> <exclude name="CallSuperInConstructor" />
<exclude name="DefaultPackage" />
</rule> </rule>
<!-- UR means "undefined reference" which is already detected by the compiler. <!-- UR means "undefined reference" which is already detected by the compiler.
......
...@@ -65,12 +65,15 @@ final class ConfigurationContext { ...@@ -65,12 +65,15 @@ final class ConfigurationContext {
addThreadableStage(sourcePort.getOwningStage(), sourcePort.getOwningStage().getId()); addThreadableStage(sourcePort.getOwningStage(), sourcePort.getOwningStage().getId());
} }
} }
if (sourcePort.getPipe() != null || targetPort.getPipe() != null) {
if (LOGGER.isWarnEnabled() && (sourcePort.getPipe() != null || targetPort.getPipe() != null)) {
LOGGER.warn("Overwriting existing pipe while connecting stages " + LOGGER.warn("Overwriting existing pipe while connecting stages " +
sourcePort.getOwningStage().getId() + " and " + targetPort.getOwningStage().getId() + "."); sourcePort.getOwningStage().getId() + " and " + targetPort.getOwningStage().getId() + ".");
} }
addChildContext(sourcePort.getOwningStage()); addChildContext(sourcePort.getOwningStage());
addChildContext(targetPort.getOwningStage()); addChildContext(targetPort.getOwningStage());
new InstantiationPipe(sourcePort, targetPort, capacity); new InstantiationPipe(sourcePort, targetPort, capacity);
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment