Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-810: rebased from master

This commit is contained in:
Mark Payne 2015-10-07 17:28:39 -04:00
parent 5ecdb1858e 2215bc848b
commit b974445ddd
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
View File

@ -1048,8 +1048,8 @@ public class StandardProcessorNode extends ProcessorNode implements Connectable
final int incomingConnCount = getIncomingConnections().size();
if (incomingConnCount != 0) {
results.add(new ValidationResult.Builder()
.explanation("Processor is currently configured with " + incomingConnCount + " upstream connections but does not accept any upstream connections")
.subject("Upstream Connections")
.explanation("Processor does not accept Incoming Connections but is currently configured with " + incomingConnCount + " Incoming Connections")
.subject("Incoming Connections")
.valid(false)
.build());
}
@ -1058,8 +1058,8 @@ public class StandardProcessorNode extends ProcessorNode implements Connectable
case INPUT_REQUIRED: {
if (getIncomingConnections().isEmpty()) {
results.add(new ValidationResult.Builder()
.explanation("Processor requires an upstream connection but currently has none")
.subject("Upstream Connections")
.explanation("Processor required at least one Incoming Connection in order to perform its function but currently has no Incoming Connection")
.subject("Incoming Connections")
.valid(false)
.build());
}
@ -1306,9 +1306,9 @@ public class StandardProcessorNode extends ProcessorNode implements Connectable
}
@Override
public void verifyModifiable() throws IllegalStateException {
if (isRunning()) {
throw new IllegalStateException("Cannot modify Processor configuration while the Processor is running");
}
}
public void verifyModifiable() throws IllegalStateException {
if (isRunning()) {
throw new IllegalStateException("Cannot modify Processor configuration while the Processor is running");
}
}>>>>>>>2215 bc848b7db395b2ca9ac7cc4dc10891393721
}