Operation message fix for service start and stop
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/bc8ea681 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/bc8ea681 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/bc8ea681 Branch: refs/heads/audit_logging Commit: bc8ea681c30ae9099ac4cc4f964844cfa58c04c7 Parents: b644807 Author: Daniel Gergely <[email protected]> Authored: Mon Feb 29 17:01:26 2016 +0100 Committer: Toader, Sebastian <[email protected]> Committed: Thu Mar 24 13:06:48 2016 +0100 ---------------------------------------------------------------------- .../audit/request/eventcreator/ServiceEventCreator.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/bc8ea681/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java b/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java index 352c3d0..09a8f89 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java @@ -132,6 +132,15 @@ public class ServiceEventCreator implements RequestAuditEventCreator { } } } + if("SERVICE".equals(request.getBody().getRequestInfoProperties().get(RequestOperationLevel.OPERATION_LEVEL_ID))) { + for (Map<String, Object> map : request.getBody().getPropertySets()) { + if (map.containsKey(PropertyHelper.getPropertyId("ServiceInfo", "state"))) { + operation = String.valueOf(map.get(PropertyHelper.getPropertyId("ServiceInfo", "state"))) + ": " + map.get(PropertyHelper.getPropertyId("ServiceInfo", "service_name")) + + " (" + request.getBody().getRequestInfoProperties().get(RequestOperationLevel.OPERATION_CLUSTER_ID) + ")"; + break; + } + } + } return operation; }
