This is an automated email from the ASF dual-hosted git repository.
aboda pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
The following commit(s) were added to refs/heads/main by this push:
new 0d5b347 MINIFICPP-1304 - InvokeHTTP can get triggered too frequently
in case flowfiles are routed back to itself
0d5b347 is described below
commit 0d5b3472669908ec051c42aeeb21709478259811
Author: Arpad Boda <[email protected]>
AuthorDate: Wed Jul 22 16:37:55 2020 +0200
MINIFICPP-1304 - InvokeHTTP can get triggered too frequently in case
flowfiles are routed back to itself
Signed-off-by: Arpad Boda <[email protected]>
Approved by szaszm on GH
This closes #847
---
extensions/http-curl/processors/InvokeHTTP.cpp | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/extensions/http-curl/processors/InvokeHTTP.cpp
b/extensions/http-curl/processors/InvokeHTTP.cpp
index 20785a0..78d9db3 100644
--- a/extensions/http-curl/processors/InvokeHTTP.cpp
+++ b/extensions/http-curl/processors/InvokeHTTP.cpp
@@ -269,7 +269,8 @@ void InvokeHTTP::onTrigger(const
std::shared_ptr<core::ProcessContext> &context,
logger_->log_debug("InvokeHTTP -- create flow file with %s", method_);
flowFile = std::static_pointer_cast<FlowFileRecord>(session->create());
} else {
- logger_->log_debug("exiting because method is %s", method_);
+ logger_->log_debug("Exiting because method is %s and there is no
flowfile available to execute it, yielding", method_);
+ yield();
return;
}
} else {