Repository: nifi-minifi Updated Branches: refs/heads/master 2b570ad03 -> 0c04fbb61
MINIFI-27 adding debug statements to BootstrapCodec This closes #16. Signed-off-by: Aldrin Piri <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi/commit/0c04fbb6 Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi/tree/0c04fbb6 Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi/diff/0c04fbb6 Branch: refs/heads/master Commit: 0c04fbb614af1b3c564e63ea2a33cabd99dfaa52 Parents: 2b570ad Author: Joseph Percivall <[email protected]> Authored: Fri Apr 22 10:56:45 2016 -0400 Committer: Aldrin Piri <[email protected]> Committed: Mon Apr 25 09:37:12 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/minifi/bootstrap/BootstrapCodec.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/0c04fbb6/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapCodec.java ---------------------------------------------------------------------- diff --git a/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapCodec.java b/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapCodec.java index bab2f9e..7629080 100644 --- a/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapCodec.java +++ b/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/BootstrapCodec.java @@ -17,6 +17,8 @@ package org.apache.nifi.minifi.bootstrap; import org.apache.nifi.minifi.bootstrap.exception.InvalidCommandException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.io.BufferedReader; import java.io.BufferedWriter; @@ -32,6 +34,7 @@ public class BootstrapCodec { private final RunMiNiFi runner; private final BufferedReader reader; private final BufferedWriter writer; + private final Logger logger = LoggerFactory.getLogger(BootstrapCodec.class); public BootstrapCodec(final RunMiNiFi runner, final InputStream in, final OutputStream out) { this.runner = runner; @@ -64,6 +67,7 @@ public class BootstrapCodec { private void processRequest(final String cmd, final String[] args) throws InvalidCommandException, IOException { switch (cmd) { case "PORT": { + logger.debug("Received 'PORT' command from MINIFI"); if (args.length != 2) { throw new InvalidCommandException(); } @@ -88,6 +92,7 @@ public class BootstrapCodec { } break; case "STARTED": { + logger.debug("Received 'STARTED' command from MINIFI"); if (args.length != 1) { throw new InvalidCommandException("STARTED command must contain a status argument"); } @@ -104,6 +109,7 @@ public class BootstrapCodec { } break; case "SHUTDOWN": { + logger.debug("Received 'SHUTDOWN' command from MINIFI"); runner.shutdownChangeNotifiers(); writer.write("OK"); writer.newLine();
