Skip to content
This repository has been archived by the owner on Nov 9, 2017. It is now read-only.

Commit

Permalink
Update OutOfBox Alert and Event generation to be in line with Hawkula…
Browse files Browse the repository at this point in the history
…r Provider Needs

- ensure that deployment events supply appropriate Tag/Context values
- remove all OOB Alerting for Hawkular-Services. [Group] Triggers will
  now be defined for Hawkular-services via MIQ or for
  a community install via REST API.  The community version UI still
  supports an Alert Center but triggers will be custom.
  • Loading branch information
jshaughn committed May 16, 2016
1 parent c6aaff4 commit 6f5f654
Show file tree
Hide file tree
Showing 2 changed files with 37 additions and 779 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@
import org.jboss.logging.Logger;

/**
* Consume Command Gateway Events, convert to Hawkular Events and forward to alerts engine for persistence/evaluation.
* Consume Command Gateway Events, convert to Hawkular Events and forward for persistence/evaluation.
* <p>
* This is useful only when deploying into the Hawkular Bus with Hawkular Command Gateway. The expected message
* payload should be a command pojo.
Expand Down Expand Up @@ -68,18 +68,15 @@ protected void onBasicMessage(BasicMessage msg) {
String canonicalPathString = dar.getResourcePath();
CanonicalPath canonicalPath = CanonicalPath.fromString(canonicalPathString);
String tenantId = canonicalPath.ids().getTenantId();
String feedId = canonicalPath.ids().getFeedId();
String resourceId = canonicalPath.ids().getResourcePath().getSegment().getElementId();
resourceId = resourceId.substring(0, resourceId.length() - 2); // trim trailing '~~'
String eventId = UUID.randomUUID().toString();
String dataId = feedId + "/" + resourceId + "_DeployApplicationResponse";
String category = "Hawkular Deployment";
String text = dar.getStatus().name();
Event event = new Event(tenantId, eventId, dataId, category, text);
event.addContext("CanonicalPath", canonicalPathString);
event.addContext("Message", dar.getMessage());

log.debugf("Received message [%s] and forwarding it to Alerts as event [%s]", dar, event);
String text = dar.getStatus().name().toLowerCase();
Event event = new Event(tenantId, eventId, category, text);
event.addContext("resource_path", canonicalPathString);
event.addContext("message", dar.getMessage());
event.addTag("miq.event_type", "hawkular_deployment." + ("error".equals(text) ? text : "ok"));
event.addTag("miq.resource_type", "MiddlewareServer");
log.debugf("Received message [%s] and forwarding it as [%s]", dar, event);

alerts.addEvents(Collections.singleton(event));

Expand Down

0 comments on commit 6f5f654

Please sign in to comment.