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/12/15 21:34:10 UTC
nifi-minifi-cpp git commit: MINIFI-161: Provide command and arguments
as attributes in ExecuteProcess
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 <al...@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 <rg...@gmail.com>
Authored: Thu Dec 15 11:28:42 2016 -0500
Committer: Aldrin Piri <al...@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