Repository: nifi Updated Branches: refs/heads/master 98cd9ad53 -> 9c9215982
NIFI-4999: Added request URI into the "restlistener.request.uri" attribute This closes #2574. Signed-off-by: Mark Payne <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9c921598 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9c921598 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9c921598 Branch: refs/heads/master Commit: 9c9215982ff02295a79300424c3a5d154869b9ee Parents: 98cd9ad Author: sbouchex <[email protected]> Authored: Wed Mar 21 17:10:49 2018 +0100 Committer: Mark Payne <[email protected]> Committed: Wed Mar 21 13:17:17 2018 -0400 ---------------------------------------------------------------------- .../apache/nifi/processors/standard/servlets/ListenHTTPServlet.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/9c921598/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/servlets/ListenHTTPServlet.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/servlets/ListenHTTPServlet.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/servlets/ListenHTTPServlet.java index fc0644b..014fb19 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/servlets/ListenHTTPServlet.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/servlets/ListenHTTPServlet.java @@ -269,6 +269,7 @@ public class ListenHTTPServlet extends HttpServlet { flowFile = session.putAllAttributes(flowFile, attributes); session.getProvenanceReporter().receive(flowFile, request.getRequestURL().toString(), sourceSystemFlowFileIdentifier, "Remote DN=" + foundSubject, transferMillis); flowFile = session.putAttribute(flowFile, "restlistener.remote.source.host", request.getRemoteHost()); + flowFile = session.putAttribute(flowFile, "restlistener.request.uri", request.getRequestURI()); flowFile = session.putAttribute(flowFile, "restlistener.remote.user.dn", foundSubject); flowFileSet.add(flowFile);
