Lehel Boér created NIFI-11535:
---------------------------------

             Summary: Change WebSocket FlowFile removal when supplying HTTP 
headers
                 Key: NIFI-11535
                 URL: https://issues.apache.org/jira/browse/NIFI-11535
             Project: Apache NiFi
          Issue Type: Bug
            Reporter: Lehel Boér
            Assignee: Lehel Boér


               final ProcessSession session = 
processSessionFactory.createSession();
                final FlowFile flowFile = session.get();
                try {
                    webSocketClientService.connect(endpointId, 
flowFile.getAttributes());
                } finally {
                    session.remove(flowFile);
                    session.commitAsync();
                }
In case of connection failure we lose data



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to