Repository: nifi-minifi-cpp Updated Branches: refs/heads/master 3bc335c8d -> 19b74bf5f
MINIFI-161: Provide command and arguments as attributes in ExecuteProcess This closes #29. Signed-off-by: Aldrin Piri <ald...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/19b74bf5 Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/19b74bf5 Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/19b74bf5 Branch: refs/heads/master Commit: 19b74bf5f659a0e9507ea3ee9e021a3f2687b877 Parents: 3bc335c Author: Randy Gelhausen <rgel...@gmail.com> Authored: Thu Dec 15 11:28:42 2016 -0500 Committer: Aldrin Piri <ald...@apache.org> Committed: Thu Dec 15 16:33:31 2016 -0500 ---------------------------------------------------------------------- libminifi/src/ExecuteProcess.cpp | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/19b74bf5/libminifi/src/ExecuteProcess.cpp ---------------------------------------------------------------------- diff --git a/libminifi/src/ExecuteProcess.cpp b/libminifi/src/ExecuteProcess.cpp index 16d9457..569c985 100644 --- a/libminifi/src/ExecuteProcess.cpp +++ b/libminifi/src/ExecuteProcess.cpp @@ -158,6 +158,8 @@ void ExecuteProcess::onTrigger(ProcessContext *context, ProcessSession *session) FlowFileRecord *flowFile = session->create(); if (!flowFile) continue; + flowFile->addAttribute("command", _command.c_str()); + flowFile->addAttribute("command.arguments", _commandArgument.c_str()); session->write(flowFile, &callback); session->transfer(flowFile, Success); session->commit(); @@ -184,6 +186,8 @@ void ExecuteProcess::onTrigger(ProcessContext *context, ProcessSession *session) flowFile = session->create(); if (!flowFile) break; + flowFile->addAttribute("command", _command.c_str()); + flowFile->addAttribute("command.arguments", _commandArgument.c_str()); session->write(flowFile, &callback); } else @@ -206,6 +210,8 @@ void ExecuteProcess::onTrigger(ProcessContext *context, ProcessSession *session) flowFile = session->create(); if (!flowFile) continue; + flowFile->addAttribute("command", _command.c_str()); + flowFile->addAttribute("command.arguments", _commandArgument.c_str()); session->write(flowFile, &callback); } else
