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 {

Reply via email to