Fixed LogMessage when logging level is disabled
This closes
@@ -156,12 +156,9 @@ public class LogMessage extends AbstractProcessor {
break;
}
- if (!isLogLevelEnabled) {
- transferChunk(session);
- return;
- }
-
+ if (isLogLevelEnabled) {
processFlowFile(logger, logLevel, flowFile, context);
+ }
session.transfer(flowFile, REL_SUCCESS);
}
@@ -202,12 +199,4 @@ public class LogMessage extends AbstractProcessor {
logger.debug(messageToWrite);
}
}
-
- private void transferChunk(final ProcessSession session) {
- final List<FlowFile> flowFiles = session.get(CHUNK_SIZE);
- if (!flowFiles.isEmpty()) {
- session.transfer(flowFiles, REL_SUCCESS);
- }
- }
-
}
