You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by al...@apache.org on 2016/04/25 15:37:37 UTC
nifi-minifi git commit: MINIFI-27 adding debug statements to
BootstrapCodec
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 <al...@apache.org>
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 <jo...@yahoo.com>
Authored: Fri Apr 22 10:56:45 2016 -0400
Committer: Aldrin Piri <al...@apache.org>
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();