NIFI-1042 Adds restlistener.remote.source.ip attribute to ListenHTTPServlet. This closes #105
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/518670db Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/518670db Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/518670db Branch: refs/heads/NIFI-655 Commit: 518670dbf66a20855357fc379f516f488921d0c5 Parents: b809031 Author: Andre F de Miranda <trixpan@@users.noreply.github.com> Authored: Mon Oct 19 23:43:31 2015 -0400 Committer: Tony Kurc <trk...@gmail.com> Committed: Mon Oct 19 23:43:44 2015 -0400 ---------------------------------------------------------------------- .../apache/nifi/processors/standard/servlets/ListenHTTPServlet.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/518670db/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 79d3887..d740f93 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.remote.user.dn", foundSubject); flowFileSet.add(flowFile);
