eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject [19/84] [partial] eagle git commit: Clean repo for eagle site
Date Mon, 03 Apr 2017 11:54:27 GMT
http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/spout/SpoutOutputCollectorWrapper.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/spout/SpoutOutputCollectorWrapper.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/spout/SpoutOutputCollectorWrapper.java
deleted file mode 100644
index 1036a36..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/spout/SpoutOutputCollectorWrapper.java
+++ /dev/null
@@ -1,229 +0,0 @@
-/*
- *
- *  * Licensed to the Apache Software Foundation (ASF) under one or more
- *  * contributor license agreements.  See the NOTICE file distributed with
- *  * this work for additional information regarding copyright ownership.
- *  * The ASF licenses this file to You under the Apache License, Version 2.0
- *  * (the "License"); you may not use this file except in compliance with
- *  * the License.  You may obtain a copy of the License at
- *  *
- *  *    http://www.apache.org/licenses/LICENSE-2.0
- *  *
- *  * Unless required by applicable law or agreed to in writing, software
- *  * distributed under the License is distributed on an "AS IS" BASIS,
- *  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  * See the License for the specific language governing permissions and
- *  * limitations under the License.
- *
- */
-package org.apache.eagle.alert.engine.spout;
-
-import backtype.storm.spout.ISpoutOutputCollector;
-import backtype.storm.spout.SpoutOutputCollector;
-import org.apache.commons.lang3.builder.HashCodeBuilder;
-import org.apache.eagle.alert.coordination.model.SpoutSpec;
-import org.apache.eagle.alert.coordination.model.StreamRepartitionMetadata;
-import org.apache.eagle.alert.coordination.model.StreamRepartitionStrategy;
-import org.apache.eagle.alert.coordination.model.Tuple2StreamConverter;
-import org.apache.eagle.alert.engine.coordinator.StreamDefinition;
-import org.apache.eagle.alert.engine.coordinator.StreamPartition;
-import org.apache.eagle.alert.engine.model.PartitionedEvent;
-import org.apache.eagle.alert.engine.model.StreamEvent;
-import org.apache.eagle.alert.engine.serialization.PartitionedEventSerializer;
-import org.apache.eagle.alert.engine.serialization.SerializationMetadataProvider;
-import org.apache.eagle.alert.utils.StreamIdConversion;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-
-/**
- * intercept the message sent from within KafkaSpout and select downstream bolts based on meta-data
- * This is topic based. each topic will have one SpoutOutputCollectorWrapper.
- */
-public class SpoutOutputCollectorWrapper extends SpoutOutputCollector implements ISpoutSpecLCM, SerializationMetadataProvider {
-    private static final Logger LOG = LoggerFactory.getLogger(SpoutOutputCollectorWrapper.class);
-
-    private final ISpoutOutputCollector delegate;
-    private final String topic;
-    private final PartitionedEventSerializer serializer;
-    private int numOfRouterBolts;
-    private boolean logEventEnabled;
-
-    private volatile List<StreamRepartitionMetadata> streamRepartitionMetadataList;
-    private volatile Tuple2StreamConverter converter;
-    private CorrelationSpout spout;
-    private volatile Map<String, StreamDefinition> sds;
-
-    /**
-     * @param delegate        actual SpoutOutputCollector to send data to following bolts
-     * @param topic           topic for this KafkaSpout to handle
-     * @param numGroupbyBolts bolts following this spout.
-     * @param serializer
-     */
-    public SpoutOutputCollectorWrapper(CorrelationSpout spout,
-                                       ISpoutOutputCollector delegate,
-                                       String topic,
-                                       SpoutSpec spoutSpec,
-                                       int numGroupbyBolts,
-                                       Map<String, StreamDefinition> sds, PartitionedEventSerializer serializer, boolean logEventEnabled) {
-        super(delegate);
-        this.spout = spout;
-        this.delegate = delegate;
-        this.topic = topic;
-        this.streamRepartitionMetadataList = spoutSpec.getStreamRepartitionMetadataMap().get(topic);
-        this.converter = new Tuple2StreamConverter(spoutSpec.getTuple2StreamMetadataMap().get(topic));
-        this.numOfRouterBolts = numGroupbyBolts;
-        this.sds = sds;
-        this.serializer = serializer;
-        this.logEventEnabled = logEventEnabled;
-    }
-
-    /**
-     * How to assert that numTotalGroupbyBolts >= numOfRouterBolts, otherwise
-     * there is runtime issue by default, tuple includes 2 fields field 1: topic
-     * name field 2: map of key/value.
-     */
-    @SuppressWarnings("rawtypes")
-    @Override
-    public List<Integer> emit(List<Object> tuple, Object messageId) {
-        if (!sanityCheck()) {
-            LOG.error(
-                "spout collector for topic {} see monitored metadata invalid, is this data source removed! Trigger message id {} ",
-                topic, messageId);
-            return null;
-        }
-
-        KafkaMessageIdWrapper newMessageId = new KafkaMessageIdWrapper(messageId);
-        newMessageId.topic = topic;
-        newMessageId.timestamp = System.currentTimeMillis();
-        /**
-         phase 1: tuple to stream converter
-         if this topic multiplexes multiple streams, then retrieve the individual streams.
-         */
-        List<Object> convertedTuple = converter.convert(tuple);
-        if (convertedTuple == null) {
-            LOG.debug("source data {} can't be converted to a stream, ignore this message", tuple);
-            spout.ack(newMessageId);
-            return null;
-        }
-        Map m = (Map) convertedTuple.get(3);
-        Object streamId = convertedTuple.get(1);
-
-        StreamDefinition sd = sds.get(streamId);
-        if (sd == null) {
-            LOG.warn("StreamDefinition {} is not found within {}, ignore this message", streamId, sds);
-            spout.ack(newMessageId);
-            return null;
-        }
-
-        StreamEvent event = convertToStreamEventByStreamDefinition((Long) convertedTuple.get(2), m, sds.get(streamId));
-        if (logEventEnabled) {
-            LOG.info("Spout from topic {} emit event: {}", topic, event);
-        }
-        
-        /*
-            phase 2: stream repartition
-        */
-        for (StreamRepartitionMetadata md : streamRepartitionMetadataList) {
-            if (!event.getStreamId().equals(md.getStreamId())) {
-                continue;
-            }
-            // one stream may have multiple group-by strategies, each strategy is for a specific group-by
-            for (StreamRepartitionStrategy groupingStrategy : md.groupingStrategies) {
-                int hash = 0;
-                if (groupingStrategy.getPartition().getType().equals(StreamPartition.Type.GROUPBY)) {
-                    hash = getRoutingHashByGroupingStrategy(m, groupingStrategy);
-                } else if (groupingStrategy.getPartition().getType().equals(StreamPartition.Type.SHUFFLE)) {
-                    hash = Math.abs((int) System.currentTimeMillis());
-                }
-                int mod = hash % groupingStrategy.numTotalParticipatingRouterBolts;
-                // filter out message
-                if (mod >= groupingStrategy.startSequence && mod < groupingStrategy.startSequence + numOfRouterBolts) {
-                    // framework takes care of field grouping instead of using storm internal field grouping
-                    String sid = StreamIdConversion.generateStreamIdBetween(spout.getSpoutName(), spout.getRouteBoltName() + (hash % numOfRouterBolts));
-                    if (LOG.isDebugEnabled()) {
-                        LOG.debug("Emitted tuple: {} with message Id: {}, with topic {}, to streamId {}", convertedTuple, messageId, topic, sid);
-                    }
-                    // send message to StreamRouterBolt
-                    PartitionedEvent pEvent = new PartitionedEvent(event, groupingStrategy.partition, hash);
-                    if (this.serializer == null) {
-                        delegate.emit(sid, Collections.singletonList(pEvent), newMessageId);
-                    } else {
-                        try {
-                            delegate.emit(sid, Collections.singletonList(serializer.serialize(pEvent)), newMessageId);
-                        } catch (Exception e) {
-                            LOG.error("Failed to serialize {}, this message would be ignored!", pEvent, e);
-                            spout.ack(newMessageId);
-                        }
-                    }
-                } else {
-                    // ******* short-cut ack ********
-                    // we should simply ack those messages which are not processed in this topology because KafkaSpout implementation requires _pending is empty
-                    // before moving to next offsets.
-                    if (LOG.isDebugEnabled()) {
-                        LOG.debug("Message filtered with mod {} not within range {} and {} for message {}", mod, groupingStrategy.startSequence,
-                            groupingStrategy.startSequence + numOfRouterBolts, tuple);
-                    }
-                    spout.ack(newMessageId);
-                }
-            }
-        }
-
-        return null;
-    }
-
-    @SuppressWarnings("rawtypes")
-    private int getRoutingHashByGroupingStrategy(Map data, StreamRepartitionStrategy gs) {
-        // calculate hash value for values from group-by fields
-        HashCodeBuilder hashCodeBuilder = new HashCodeBuilder();
-        for (String groupingField : gs.partition.getColumns()) {
-            if (data.get(groupingField) != null) {
-                hashCodeBuilder.append(data.get(groupingField));
-            } else {
-                LOG.warn("Required GroupBy fields {} not found: {}", gs.partition.getColumns(), data);
-            }
-        }
-        int hash = hashCodeBuilder.toHashCode();
-        hash = Math.abs(hash);
-        return hash;
-    }
-
-    private boolean sanityCheck() {
-        boolean isOk = true;
-        if (streamRepartitionMetadataList == null) {
-            LOG.error("streamRepartitionMetadataList is null!");
-            isOk = false;
-        }
-        if (converter == null) {
-            LOG.error("tuple2StreamMetadata is null!");
-            isOk = false;
-        }
-        return isOk;
-    }
-
-    @SuppressWarnings( {"rawtypes", "unchecked"})
-    private StreamEvent convertToStreamEventByStreamDefinition(long timestamp, Map m, StreamDefinition sd) {
-        return StreamEvent.builder().timestamep(timestamp).attributes(m, sd).build();
-    }
-
-    /**
-     * SpoutSpec may be changed, this class will respond to changes on tuple2StreamMetadataMap and streamRepartitionMetadataMap.
-     *
-     * @param spoutSpec
-     * @param sds
-     */
-    @Override
-    public void update(SpoutSpec spoutSpec, Map<String, StreamDefinition> sds) {
-        this.streamRepartitionMetadataList = spoutSpec.getStreamRepartitionMetadataMap().get(topic);
-        this.converter = new Tuple2StreamConverter(spoutSpec.getTuple2StreamMetadataMap().get(topic));
-        this.sds = sds;
-    }
-
-    @Override
-    public StreamDefinition getStreamDefinition(String streamId) {
-        return this.sds.get(streamId);
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/AlertStreamUtils.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/AlertStreamUtils.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/AlertStreamUtils.java
deleted file mode 100644
index fc9cc8a..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/AlertStreamUtils.java
+++ /dev/null
@@ -1,58 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.eagle.alert.engine.utils;
-
-import org.apache.eagle.alert.engine.coordinator.PolicyDefinition;
-import org.apache.eagle.alert.engine.coordinator.StreamDefinition;
-import org.apache.eagle.alert.engine.evaluator.PolicyHandlerContext;
-import org.apache.eagle.alert.engine.model.AlertStreamEvent;
-import org.apache.eagle.alert.engine.model.StreamEvent;
-
-import java.util.Map;
-
-/**
- * Created on 8/16/16.
- */
-public class AlertStreamUtils {
-
-    /**
-     * Create alert stream event for publisher.
-     */
-    public static AlertStreamEvent createAlertEvent(StreamEvent event,
-                                                    PolicyHandlerContext context,
-                                                    Map<String, StreamDefinition> sds) {
-        PolicyDefinition policyDef = context.getPolicyDefinition();
-        AlertStreamEvent alertStreamEvent = new AlertStreamEvent();
-
-        alertStreamEvent.setTimestamp(event.getTimestamp());
-        alertStreamEvent.setData(event.getData());
-        alertStreamEvent.setStreamId(policyDef.getOutputStreams().get(0));
-        alertStreamEvent.setPolicyId(policyDef.getName());
-
-        if (context.getPolicyEvaluator() != null) {
-            alertStreamEvent.setCreatedBy(context.getPolicyEvaluator().getName());
-        }
-
-        alertStreamEvent.setCreatedTime(System.currentTimeMillis());
-
-        String is = policyDef.getInputStreams().get(0);
-        StreamDefinition sd = sds.get(is);
-        alertStreamEvent.setSchema(sd);
-
-        return alertStreamEvent;
-    }
-}

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/CompressionUtils.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/CompressionUtils.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/CompressionUtils.java
deleted file mode 100644
index 075d827..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/CompressionUtils.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- * <p/>
- * http://www.apache.org/licenses/LICENSE-2.0
- * <p/>
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.eagle.alert.engine.utils;
-
-import com.google.common.io.ByteStreams;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.util.zip.GZIPInputStream;
-import java.util.zip.GZIPOutputStream;
-
-
-public class CompressionUtils {
-    public static byte[] compress(byte[] source) throws IOException {
-        if (source == null || source.length == 0) {
-            return source;
-        }
-        ByteArrayInputStream sourceStream = new ByteArrayInputStream(source);
-        ByteArrayOutputStream outputStream = new ByteArrayOutputStream(source.length / 2);
-        try (OutputStream compressor = new GZIPOutputStream(outputStream)) {
-            ByteStreams.copy(sourceStream, compressor);
-            compressor.close();
-        }
-        try {
-            return outputStream.toByteArray();
-        } finally {
-            sourceStream.close();
-            outputStream.close();
-        }
-    }
-
-    public static byte[] decompress(byte[] compressed) throws IOException {
-        if (compressed == null || compressed.length == 0) {
-            return compressed;
-        }
-        ByteArrayInputStream sourceStream = new ByteArrayInputStream(compressed);
-        ByteArrayOutputStream outputStream = new ByteArrayOutputStream(compressed.length * 2);
-        try (GZIPInputStream compressor = new GZIPInputStream(sourceStream)) {
-            ByteStreams.copy(compressor, outputStream);
-            compressor.close();
-        }
-        try {
-            return outputStream.toByteArray();
-        } finally {
-            sourceStream.close();
-            outputStream.close();
-        }
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/MetadataSerDeser.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/MetadataSerDeser.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/MetadataSerDeser.java
deleted file mode 100644
index 2229219..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/MetadataSerDeser.java
+++ /dev/null
@@ -1,103 +0,0 @@
-/*
- *
- *  * Licensed to the Apache Software Foundation (ASF) under one or more
- *  * contributor license agreements.  See the NOTICE file distributed with
- *  * this work for additional information regarding copyright ownership.
- *  * The ASF licenses this file to You under the Apache License, Version 2.0
- *  * (the "License"); you may not use this file except in compliance with
- *  * the License.  You may obtain a copy of the License at
- *  *
- *  *    http://www.apache.org/licenses/LICENSE-2.0
- *  *
- *  * Unless required by applicable law or agreed to in writing, software
- *  * distributed under the License is distributed on an "AS IS" BASIS,
- *  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  * See the License for the specific language governing permissions and
- *  * limitations under the License.
- *
- */
-
-package org.apache.eagle.alert.engine.utils;
-
-import com.fasterxml.jackson.core.JsonParser;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.InputStream;
-
-/**
- * Since 5/6/16.
- */
-public class MetadataSerDeser {
-    private static final Logger LOG = LoggerFactory.getLogger(MetadataSerDeser.class);
-
-    @SuppressWarnings("rawtypes")
-    public static <K> K deserialize(InputStream is, TypeReference typeRef) {
-        ObjectMapper mapper = new ObjectMapper();
-        try {
-            K spec = mapper.readValue(is, typeRef);
-            return spec;
-        } catch (Exception ex) {
-            LOG.error("error in deserializing metadata of type {} from input stream",
-                new TypeReference<K>() {
-                }.getType().getClass().getCanonicalName(), ex);
-        }
-        return null;
-    }
-
-    public static <K> K deserialize(InputStream is, Class<K> cls) {
-        ObjectMapper mapper = new ObjectMapper();
-        mapper.configure(JsonParser.Feature.ALLOW_COMMENTS, true);
-        try {
-            K spec = mapper.readValue(is, cls);
-            return spec;
-        } catch (Exception ex) {
-            LOG.error("Got error to deserialize metadata of type {} from input stream",
-                new TypeReference<K>() {
-                }.getType().getClass().getCanonicalName(), ex);
-        }
-        return null;
-    }
-
-    @SuppressWarnings("rawtypes")
-    public static <K> K deserialize(String json, TypeReference typeRef) {
-        ObjectMapper mapper = new ObjectMapper();
-        try {
-            K spec = mapper.readValue(json, typeRef);
-            return spec;
-        } catch (Exception ex) {
-            LOG.error("error in deserializing metadata of type {} from {}",
-                new TypeReference<K>() {
-                }.getType().getClass().getCanonicalName(), json, ex);
-        }
-        return null;
-    }
-
-    public static <K> K deserialize(String json, Class<K> cls) {
-        ObjectMapper mapper = new ObjectMapper();
-        try {
-            K spec = mapper.readValue(json, cls);
-            return spec;
-        } catch (Exception ex) {
-            LOG.error("error in deserializing metadata of type {} from {}",
-                new TypeReference<K>() {
-                }.getType().getClass().getCanonicalName(), json, ex);
-        }
-        return null;
-    }
-
-    public static <K> String serialize(K spec) {
-        ObjectMapper mapper = new ObjectMapper();
-        try {
-            String json = mapper.writeValueAsString(spec);
-            return json;
-        } catch (Exception ex) {
-            LOG.error("error in serializing object {} with type {}", spec,
-                new TypeReference<K>() {
-                }.getType().getClass().getCanonicalName(), ex);
-        }
-        return null;
-    }
-}

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/SerializableUtils.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/SerializableUtils.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/SerializableUtils.java
deleted file mode 100644
index 509cbf4..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/SerializableUtils.java
+++ /dev/null
@@ -1,122 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.eagle.alert.engine.utils;
-
-import org.xerial.snappy.SnappyInputStream;
-import org.xerial.snappy.SnappyOutputStream;
-
-import java.io.*;
-
-
-/**
- * Utilities for working with Serializables.
- * Derived from "com.google.cloud.dataflow.sdk.util.SerializableUtils"
- */
-public class SerializableUtils {
-    /**
-     * Serializes the argument into an array of bytes, and returns it.
-     *
-     * @throws IllegalArgumentException if there are errors when serializing
-     */
-    public static byte[] serializeToCompressedByteArray(Object value) {
-        try {
-            ByteArrayOutputStream buffer = new ByteArrayOutputStream();
-            try (ObjectOutputStream oos = new ObjectOutputStream(new SnappyOutputStream(buffer))) {
-                oos.writeObject(value);
-            }
-            return buffer.toByteArray();
-        } catch (IOException exn) {
-            throw new IllegalArgumentException(
-                "unable to serialize " + value,
-                exn);
-        }
-    }
-
-    /**
-     * Serializes the argument into an array of bytes, and returns it.
-     *
-     * @throws IllegalArgumentException if there are errors when serializing
-     */
-    public static byte[] serializeToByteArray(Object value) {
-        try {
-            ByteArrayOutputStream buffer = new ByteArrayOutputStream();
-            try (ObjectOutputStream oos = new ObjectOutputStream(buffer)) {
-                oos.writeObject(value);
-            }
-            return buffer.toByteArray();
-        } catch (IOException exn) {
-            throw new IllegalArgumentException("unable to serialize " + value, exn);
-        }
-    }
-
-    /**
-     * Deserializes an object from the given array of bytes, e.g., as
-     * serialized using {@link #serializeToCompressedByteArray}, and returns it.
-     *
-     * @throws IllegalArgumentException if there are errors when
-     *                                  deserializing, using the provided description to identify what
-     *                                  was being deserialized
-     */
-    public static Object deserializeFromByteArray(byte[] encodedValue,
-                                                  String description) {
-        try {
-            try (ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(encodedValue))) {
-                return ois.readObject();
-            }
-        } catch (IOException | ClassNotFoundException exn) {
-            throw new IllegalArgumentException(
-                "unable to deserialize " + description,
-                exn);
-        }
-    }
-
-    /**
-     * Deserializes an object from the given array of bytes, e.g., as
-     * serialized using {@link #serializeToCompressedByteArray}, and returns it.
-     *
-     * @throws IllegalArgumentException if there are errors when
-     *                                  deserializing, using the provided description to identify what
-     *                                  was being deserialized
-     */
-    public static Object deserializeFromCompressedByteArray(byte[] encodedValue,
-                                                            String description) {
-        try {
-            try (ObjectInputStream ois = new ObjectInputStream(
-                new SnappyInputStream(new ByteArrayInputStream(encodedValue)))) {
-                return ois.readObject();
-            }
-        } catch (IOException | ClassNotFoundException exn) {
-            throw new IllegalArgumentException(
-                "unable to deserialize " + description,
-                exn);
-        }
-    }
-
-    public static <T extends Serializable> T ensureSerializable(T value) {
-        @SuppressWarnings("unchecked")
-        T copy = (T) deserializeFromCompressedByteArray(serializeToCompressedByteArray(value),
-            value.toString());
-        return copy;
-    }
-
-    public static <T extends Serializable> T clone(T value) {
-        @SuppressWarnings("unchecked")
-        T copy = (T) deserializeFromCompressedByteArray(serializeToCompressedByteArray(value),
-            value.toString());
-        return copy;
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/SingletonExecutor.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/SingletonExecutor.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/SingletonExecutor.java
deleted file mode 100644
index fdb9ed8..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/utils/SingletonExecutor.java
+++ /dev/null
@@ -1,44 +0,0 @@
-/*
- *
- *  * Licensed to the Apache Software Foundation (ASF) under one or more
- *  * contributor license agreements.  See the NOTICE file distributed with
- *  * this work for additional information regarding copyright ownership.
- *  * The ASF licenses this file to You under the Apache License, Version 2.0
- *  * (the "License"); you may not use this file except in compliance with
- *  * the License.  You may obtain a copy of the License at
- *  *
- *  *    http://www.apache.org/licenses/LICENSE-2.0
- *  *
- *  * Unless required by applicable law or agreed to in writing, software
- *  * distributed under the License is distributed on an "AS IS" BASIS,
- *  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  * See the License for the specific language governing permissions and
- *  * limitations under the License.
- *
- */
-
-package org.apache.eagle.alert.engine.utils;
-
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-public class SingletonExecutor {
-
-    public static synchronized ExecutorService getExecutorService() {
-        return executorService;
-    }
-
-    private static ExecutorService executorService;
-
-    private static SingletonExecutor executor = new SingletonExecutor();
-
-    public SingletonExecutor() {
-        executorService = Executors.newFixedThreadPool(5);
-    }
-
-    public static void main(String[] args) {
-        System.out.println(SingletonExecutor.getExecutorService());
-        System.out.println(SingletonExecutor.getExecutorService());
-
-    }
-}

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/storm/kafka/KafkaSpoutMetric.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/storm/kafka/KafkaSpoutMetric.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/storm/kafka/KafkaSpoutMetric.java
deleted file mode 100644
index 935742f..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/storm/kafka/KafkaSpoutMetric.java
+++ /dev/null
@@ -1,89 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package storm.kafka;
-
-import backtype.storm.metric.api.IMetric;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.*;
-import java.util.concurrent.ConcurrentHashMap;
-
-/**
- * Since 5/18/16.
- * The original storm.kafka.KafkaSpout has some issues like the following
- * 1) can only support one single topic
- * 2) can only be initialized at open(), can't dynamically support another topic.
- */
-public class KafkaSpoutMetric implements IMetric {
-    @SuppressWarnings("unused")
-    private static final Logger LOG = LoggerFactory.getLogger(KafkaSpoutMetric.class);
-    private Map<String, KafkaSpoutMetricContext> metricContextMap = new ConcurrentHashMap<>();
-    private Map<String, KafkaUtils.KafkaOffsetMetric> offsetMetricMap = new ConcurrentHashMap<>();
-
-    public static class KafkaSpoutMetricContext {
-        SpoutConfig spoutConfig;
-        DynamicPartitionConnections connections;
-        PartitionCoordinator coordinator;
-    }
-
-    public void addTopic(String topic, KafkaSpoutMetricContext context) {
-        // construct KafkaOffsetMetric
-        KafkaUtils.KafkaOffsetMetric kafkaOffsetMetric = new KafkaUtils.KafkaOffsetMetric(context.spoutConfig.topic, context.connections);
-        metricContextMap.put(topic, context);
-        offsetMetricMap.put(topic, kafkaOffsetMetric);
-    }
-
-    public void removeTopic(String topic) {
-        metricContextMap.remove(topic);
-        offsetMetricMap.remove(topic);
-    }
-
-    @SuppressWarnings( {"unchecked", "rawtypes"})
-    @Override
-    public Object getValueAndReset() {
-        HashMap spoutMetric = new HashMap();
-        for (Map.Entry<String, KafkaSpoutMetricContext> entry : metricContextMap.entrySet()) {
-            // construct offset metric
-            List<PartitionManager> pms = entry.getValue().coordinator.getMyManagedPartitions();
-            Set<Partition> latestPartitions = new HashSet();
-            for (PartitionManager pm : pms) {
-                latestPartitions.add(pm.getPartition());
-            }
-
-            KafkaUtils.KafkaOffsetMetric offsetMetric = offsetMetricMap.get(entry.getKey());
-            offsetMetric.refreshPartitions(latestPartitions);
-            for (PartitionManager pm : pms) {
-                offsetMetric.setLatestEmittedOffset(pm.getPartition(), pm.lastCompletedOffset());
-            }
-            Object o = offsetMetric.getValueAndReset();
-            if (o != null) {
-                ((HashMap) o).forEach(
-                    (k, v) -> spoutMetric.put(k + "_" + entry.getKey(), v)
-                );
-            }
-
-            // construct partition metric
-            for (PartitionManager pm : pms) {
-                pm.getMetricsDataMap().forEach(
-                    (k, v) -> spoutMetric.put(k + "_" + entry.getKey(), v)
-                );
-            }
-        }
-        return spoutMetric;
-    }
-}

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/storm/kafka/KafkaSpoutWrapper.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/storm/kafka/KafkaSpoutWrapper.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/storm/kafka/KafkaSpoutWrapper.java
deleted file mode 100644
index 2bdbd3c..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/storm/kafka/KafkaSpoutWrapper.java
+++ /dev/null
@@ -1,111 +0,0 @@
-/*
- *
- *  * Licensed to the Apache Software Foundation (ASF) under one or more
- *  * contributor license agreements.  See the NOTICE file distributed with
- *  * this work for additional information regarding copyright ownership.
- *  * The ASF licenses this file to You under the Apache License, Version 2.0
- *  * (the "License"); you may not use this file except in compliance with
- *  * the License.  You may obtain a copy of the License at
- *  *
- *  *    http://www.apache.org/licenses/LICENSE-2.0
- *  *
- *  * Unless required by applicable law or agreed to in writing, software
- *  * distributed under the License is distributed on an "AS IS" BASIS,
- *  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  * See the License for the specific language governing permissions and
- *  * limitations under the License.
- *
- */
-package storm.kafka;
-
-import org.apache.eagle.alert.coordination.model.SpoutSpec;
-import org.apache.eagle.alert.engine.coordinator.StreamDefinition;
-import org.apache.eagle.alert.engine.spout.ISpoutSpecLCM;
-import org.apache.eagle.alert.engine.spout.SpoutOutputCollectorWrapper;
-import backtype.storm.Config;
-import backtype.storm.spout.SpoutOutputCollector;
-import backtype.storm.task.TopologyContext;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * NOTE!!!!! This class copy/paste some code from storm.kafka.KafkaSpout to make sure it can support one process to hold multiple
- * KafkaSpout
- *
- * <p>this collectorWrapper provides the following capabilities:
- * 1. inject customized collector collectorWrapper, so framework can control traffic routing
- * 2. listen to topic to stream metadata change and pass that to customized collector collectorWrapper
- * 3. return current streams for this topic</p>
- */
-public class KafkaSpoutWrapper extends KafkaSpout implements ISpoutSpecLCM {
-    private static final long serialVersionUID = 5507693757424351306L;
-    @SuppressWarnings("unused")
-    private static final Logger LOG = LoggerFactory.getLogger(KafkaSpoutWrapper.class);
-    private KafkaSpoutMetric kafkaSpoutMetric;
-
-    public KafkaSpoutWrapper(SpoutConfig spoutConf, KafkaSpoutMetric kafkaSpoutMetric) {
-        super(spoutConf);
-        this.kafkaSpoutMetric = kafkaSpoutMetric;
-    }
-
-    private SpoutOutputCollectorWrapper collectorWrapper;
-
-    @SuppressWarnings( {"unchecked", "rawtypes"})
-    @Override
-    public void open(Map conf, final TopologyContext context, final SpoutOutputCollector collector) {
-        String topologyInstanceId = context.getStormId();
-        ////// !!!! begin copying code from storm.kafka.KafkaSpout to here
-        _collector = collector;
-
-        Map stateConf = new HashMap(conf);
-        List<String> zkServers = _spoutConfig.zkServers;
-        if (zkServers == null) {
-            zkServers = (List<String>) conf.get(Config.STORM_ZOOKEEPER_SERVERS);
-        }
-        Integer zkPort = _spoutConfig.zkPort;
-        if (zkPort == null) {
-            zkPort = ((Number) conf.get(Config.STORM_ZOOKEEPER_PORT)).intValue();
-        }
-        stateConf.put(Config.TRANSACTIONAL_ZOOKEEPER_SERVERS, zkServers);
-        stateConf.put(Config.TRANSACTIONAL_ZOOKEEPER_PORT, zkPort);
-        stateConf.put(Config.TRANSACTIONAL_ZOOKEEPER_ROOT, _spoutConfig.zkRoot);
-        _state = new ZkState(stateConf);
-
-        _connections = new DynamicPartitionConnections(_spoutConfig, KafkaUtils.makeBrokerReader(conf, _spoutConfig));
-
-        // using TransactionalState like this is a hack
-        int totalTasks = context.getComponentTasks(context.getThisComponentId()).size();
-        if (_spoutConfig.hosts instanceof StaticHosts) {
-            _coordinator = new StaticCoordinator(_connections, conf, _spoutConfig, _state, context.getThisTaskIndex(), totalTasks, topologyInstanceId);
-        } else {
-            _coordinator = new ZkCoordinator(_connections, conf, _spoutConfig, _state, context.getThisTaskIndex(), totalTasks, topologyInstanceId);
-        }
-
-        ////// !!!! end copying code from storm.kafka.KafkaSpout to here
-
-        // add new topic to metric
-        KafkaSpoutMetric.KafkaSpoutMetricContext metricContext = new KafkaSpoutMetric.KafkaSpoutMetricContext();
-        metricContext.connections = _connections;
-        metricContext.coordinator = _coordinator;
-        metricContext.spoutConfig = _spoutConfig;
-        kafkaSpoutMetric.addTopic(_spoutConfig.topic, metricContext);
-
-        this.collectorWrapper = (SpoutOutputCollectorWrapper) collector;
-    }
-
-    @Override
-    public void update(SpoutSpec metadata, Map<String, StreamDefinition> sds) {
-        collectorWrapper.update(metadata, sds);
-    }
-
-    @Override
-    public void close() {
-        super.close();
-        kafkaSpoutMetric.removeTopic(_spoutConfig.topic);
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_DEFAULT_TEMPLATE.vm
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_DEFAULT_TEMPLATE.vm b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_DEFAULT_TEMPLATE.vm
deleted file mode 100644
index 3926cc8..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_DEFAULT_TEMPLATE.vm
+++ /dev/null
@@ -1,301 +0,0 @@
-<!--
-  ~ Licensed to the Apache Software Foundation (ASF) under one or more
-  ~ contributor license agreements.  See the NOTICE file distributed with
-  ~ this work for additional information regarding copyright ownership.
-  ~ The ASF licenses this file to You under the Apache License, Version 2.0
-  ~ (the "License"); you may not use this file except in compliance with
-  ~ the License.  You may obtain a copy of the License at
-  ~
-  ~    http://www.apache.org/licenses/LICENSE-2.0
-  ~
-  ~ Unless required by applicable law or agreed to in writing, software
-  ~ distributed under the License is distributed on an "AS IS" BASIS,
-  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  ~ See the License for the specific language governing permissions and
-  ~ limitations under the License.
-  -->
-<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
-<html xmlns="http://www.w3.org/1999/xhtml">
-    #set ( $alert = $alertList[0] )
-<head>
-    <meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
-    <meta name="viewport" content="width=device-width"/>
-    <title>$alert["alertSubject"]</title>
-    <style>
-        body {
-            width: 100% !important;
-            min-width: 100%;
-            -webkit-text-size-adjust: 100%;
-            -ms-text-size-adjust: 100%;
-            margin: 0;
-            padding: 0;
-        }
-
-        table {
-            border-spacing: 0;
-            border-collapse: collapse;
-        }
-
-        table th,
-        table td {
-            padding: 3px 0 3px 0;
-        }
-
-        .body {
-            width: 100%;
-        }
-
-        p, a, h1, h2, h3, ul, ol, li {
-            font-family: Helvetica, Arial, sans-serif;
-            font-weight: normal;
-            margin: 0;
-            padding: 0;
-        }
-
-        p {
-            font-size: 14px;
-            line-height: 19px;
-        }
-
-        a {
-            color: #3294b1;
-        }
-
-        h1 {
-            font-size: 36px;
-            margin: 15px 0 5px 0;
-        }
-
-        h2 {
-            font-size: 32px;
-        }
-
-        h3 {
-            font-size: 28px;
-        }
-
-        ul, ol {
-            margin: 0 0 0 25px;
-            padding: 0;
-        }
-
-        .btn {
-            background: #2ba6cb !important;
-            border: 1px solid #2284a1;
-            padding: 10px 20px 10px 20px;
-            text-align: center;
-        }
-
-        .btn:hover {
-            background: #2795b6 !important;
-        }
-
-        .btn a {
-            color: #FFFFFF;
-            text-decoration: none;
-            font-weight: bold;
-            padding: 10px 20px 10px 20px;
-        }
-
-        .tableBordered {
-            border-top: 1px solid #b9e5ff;
-        }
-
-        .tableBordered th {
-            background: #ECF8FF;
-        }
-
-        .tableBordered th p {
-            font-weight: bold;
-            color: #3294b1;
-        }
-
-        .tableBordered th,
-        .tableBordered td {
-            color: #333333;
-            border-bottom: 1px solid #b9e5ff;
-            text-align: center;
-            padding-bottom: 5px;
-        }
-
-        .panel {
-            height: 100px;
-        }
-    </style>
-</head>
-<body>
-<table class="body">
-    <tr>
-        <td align="center" valign="top" style="background: #999999; padding: 0 0 0 0;">
-            <!-- Header -->
-            <table width="580">
-                <tr>
-                    <td style="padding: 0 0 0 0;" align="left">
-                        <p style="color:#FFFFFF;font-weight: bold; font-size: 22px">Eagle Alert Notification</p>
-                    </td>
-                </tr>
-            </table>
-        </td>
-    </tr>
-    <tr>
-        <td align="center" valign="top">
-            <!-- Eagle Body -->
-            <table width="580">
-                <tr>
-                    <!-- Title -->
-                    <td align="center">
-                        <h2>Warning: $alert["alertSubject"]</h2>
-                    </td>
-                </tr>
-                <tr>
-                    <!-- Time -->
-                    <td>
-                        <table width="580">
-                            <tr>
-                                <td>
-                                    <p><b>Detected Time: $alert["alertTime"]</b></p>
-                                </td>
-                                #set ( $alertSeverity = $alert["alertSeverity"] )
-                                #if (!$alertSeverity || ("$alertSeverity" == ""))
-                                    #set ( $alert["alertSeverity"] = "WARNING")
-                                #end
-                                <td align="right">
-                                    <p><b>
-                                        Severity:
-                                        #if ($alert["alertSeverity"] == "WARNING")
-                                            <span>$alert["alertSeverity"]</span>
-                                        #else
-                                            <span style="color: #FF0000;">$alert["alertSeverity"]</span>
-                                        #end
-                                    </b></p>
-                                </td>
-                            </tr>
-                        </table>
-                    </td>
-                </tr>
-
-                <tr>
-                    <!-- Basic Information -->
-                    <td style="padding: 20px 0 10px 0;">
-                        <p><b>Alert Message </b></p>
-                    </td>
-                </tr>
-                <tr>
-                    <!-- Description -->
-                    <td valign="top"
-                        style="background: #ECF8FF; border: 1px solid #b9e5ff; padding: 10px 10px 12px 20px;">
-                        <p>$alert["alertBody"]</p>
-                    </td>
-                </tr>
-                <tr>
-                    <!-- Basic Information -->
-                    <td style="padding: 20px 0 10px 0;">
-                        <p><b>Alert Detail</b></p>
-                    </td>
-                </tr>
-                <tr>
-                    <!-- Basic Information Content -->
-                    <td>
-                        <table class="tableBordered" width="580">
-                            <tr>
-                                <th>
-                                    <p>Policy Name</p>
-                                </th>
-                                <td>
-                                    <p><a href="$alert["policyDetailUrl"]">$alert["policyId"]</a></p>
-                                </td>
-                            </tr>
-                            <tr>
-                                <th>
-                                    <p>Severity Level</p>
-                                </th>
-                                <td>
-                                    <p>$alert["alertSeverity"]</p>
-                                </td>
-                            </tr>
-                            <tr>
-                                <th>
-                                    <p>Alert Stream</p>
-                                </th>
-                                <td>
-                                    <p>$alert["streamId"]</p>
-                                </td>
-                            </tr>
-                            <tr>
-                                <th>
-                                    <p>Created Time</p>
-                                </th>
-                                <td>
-                                    <p>$alert["alertTime"]</p>
-                                </td>
-                            </tr>
-                            <tr>
-                                <th>
-                                    <p>Created By</p>
-                                </th>
-                                <td>
-                                    <p>$alert["creator"]</p>
-                                </td>
-                            </tr>
-                        </table>
-                    </td>
-                </tr>
-##                <tr>
-##                    <!-- View Detail -->
-##                    <td align="center" style="padding: 10px 0 0 0;">
-##                        <table width="580">
-##                            <tr>
-##                                <td class="btn">
-##                                    <a href="$alert["policyDetailUrl"]">View Policy Details</a>
-##                                </td>
-##                            </tr>
-##                        </table>
-##                    </td>
-##                </tr>
-
-                <tr>
-                    <!-- View Detail -->
-                    <td align="center" style="padding: 10px 0 0 0;">
-                        <table width="580">
-                            <tr>
-                                <td class="btn">
-                                    <a href="$alert["alertDetailUrl"]">View Alert on Eagle</a>
-                                </td>
-                            </tr>
-                        </table>
-                    </td>
-                </tr>
-                <tr>
-                    <!-- Actions Required -->
-                    <td style="padding: 20px 0 10px 0;">
-                        <p><b>Actions Required</b></p>
-                    </td>
-                </tr>
-                <tr>
-                    <!-- Possible Root Causes Content -->
-                    <td class="panel" valign="top"
-                        style="background: #F4F4F4; border: 1px solid #AAAAAA; padding: 10px 10px 12px 10px;">
-                        <p>
-                            The alert notification was automatically detected and sent by Eagle according to policy: $alert["policyId"].
-                            To follow-up on this, please verify the alert and diagnose the root cause with Eagle:
-                        </p>
-                        <p></p>
-                        <ul>
-                            <li><p><a href="$alert["alertDetailUrl"]">View alert detail</a></p></li>
-                            <li><p><a href="$alert["policyDetailUrl"]">View policy detail</a></p></li>
-                            <li><p><a href="$alert["homeUrl"]">View eagle home</a></p></li>
-                        </ul>
-                    </td>
-                </tr>
-                <tr>
-                    <!-- Copyright -->
-                    <td align="center">
-                        <p><i>Powered by <a href="http://eagle.incubator.apache.org">Apache Eagle</a> (version: $alert["version"])</i></p>
-                    </td>
-                </tr>
-            </table>
-        </td>
-    </tr>
-</table>
-</body>
-</html>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_INLINED_TEMPLATE.vm
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_INLINED_TEMPLATE.vm b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_INLINED_TEMPLATE.vm
deleted file mode 100644
index 0e3d5fe..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_INLINED_TEMPLATE.vm
+++ /dev/null
@@ -1,259 +0,0 @@
-<!--
-  ~ Licensed to the Apache Software Foundation (ASF) under one or more
-  ~ contributor license agreements.  See the NOTICE file distributed with
-  ~ this work for additional information regarding copyright ownership.
-  ~ The ASF licenses this file to You under the Apache License, Version 2.0
-  ~ (the "License"); you may not use this file except in compliance with
-  ~ the License.  You may obtain a copy of the License at
-  ~
-  ~    http://www.apache.org/licenses/LICENSE-2.0
-  ~
-  ~ Unless required by applicable law or agreed to in writing, software
-  ~ distributed under the License is distributed on an "AS IS" BASIS,
-  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  ~ See the License for the specific language governing permissions and
-  ~ limitations under the License.
-  -->
-<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
-        "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
-
-#set ( $alert = $alertList[0] )
-
-## Generate Alert Color
-#set($alertColor = "#337ab7")
-#if($alert["alertSeverity"] == "WARNING")
-    #set($alertColor = "#FF9F00")
-#elseif($alert["alertSeverity"] == "CRITICAL" || $alert["alertSeverity"] == "FETAL")
-    #set($alertColor = "#d43f3a")
-#elseif ($alert["alertSeverity"] == "OK")
-    #set($alertColor = "#68B90F")
-#end
-
-<html xmlns="http://www.w3.org/1999/xhtml"
-      style="font-family: 'Helvetica Neue', Helvetica, Arial, sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-<head>
-    <meta name="viewport" content="width=device-width"/>
-    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>
-    <title>[$alert["alertSeverity"] $alert["alertSubject"]</title>
-    <style type="text/css">
-        img {
-            max-width: 100%;
-        }
-
-        body {
-            -webkit-font-smoothing: antialiased;
-            -webkit-text-size-adjust: none;
-            width: 100% !important;
-            height: 100%;
-            line-height: 1.6em;
-        }
-
-        body {
-            background-color: #f6f6f6;
-        }
-
-        @media only screen and (max-width: 640px) {
-            body {
-                padding: 0 !important;
-            }
-
-            h1 {
-                font-weight: 800 !important;
-                margin: 20px 0 5px !important;
-            }
-
-            h2 {
-                font-weight: 800 !important;
-                margin: 20px 0 5px !important;
-            }
-
-            h3 {
-                font-weight: 800 !important;
-                margin: 20px 0 5px !important;
-            }
-
-            h4 {
-                font-weight: 800 !important;
-                margin: 20px 0 5px !important;
-            }
-
-            h1 {
-                font-size: 22px !important;
-            }
-
-            h2 {
-                font-size: 18px !important;
-            }
-
-            h3 {
-                font-size: 16px !important;
-            }
-
-            .container {
-                padding: 0 !important;
-                width: 100% !important;
-            }
-
-            .content {
-                padding: 0 !important;
-            }
-
-            .content-wrap {
-                padding: 10px !important;
-            }
-
-            .invoice {
-                width: 100% !important;
-            }
-        }
-    </style>
-</head>
-
-<body itemscope itemtype="http://schema.org/EmailMessage"
-      style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; -webkit-font-smoothing: antialiased; -webkit-text-size-adjust: none; width: 100% !important; height: 100%; line-height: 1.6em; background-color: #f6f6f6; margin: 0;"
-      bgcolor="#f6f6f6">
-
-<table class="body-wrap"
-       style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; width: 100%; background-color: #f6f6f6; margin: 0;"
-       bgcolor="#f6f6f6">
-    <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-        <td style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0;"
-            valign="top"></td>
-        <td class="container" width="600"
-            style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; display: block !important; max-width: 600px !important; clear: both !important; margin: 0 auto;"
-            valign="top">
-            <div class="content"
-                 style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; max-width: 600px; display: block; margin: 0 auto; padding: 20px;">
-                <table class="main" width="100%" cellpadding="0" cellspacing="0"
-                       style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; border-radius: 3px; background-color: #fff; margin: 0; border: 1px solid #e9e9e9;"
-                       bgcolor="#fff">
-                    <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                        <td class="alert alert-warning"
-                            style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 16px; vertical-align: top; color: #fff; font-weight: 500; text-align: center; border-radius: 3px 3px 0 0; background-color: $alertColor; margin: 0; padding: 20px;"
-                            align="center" bgcolor="$alertColor" valign="top">
-                            <strong >$alert["alertSeverity"]: </strong>
-                            $alert["alertSubject"]
-                        </td>
-                    </tr>
-                    <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                        <td class="content-wrap"
-                            style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0; padding: 20px;"
-                            valign="top">
-                            <table width="100%" cellpadding="0" cellspacing="0"
-                                   style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                            <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                <td class="content-block"
-                                    style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0; padding: 0 0 20px;"
-                                    valign="top">
-                                    <small>CATEGORY:</small> <strong style="color: $alertColor">#if($alert["alertCategory"]) $alert["alertCategory"] #else N/A #end</strong> <small>TIME:</small> <strong>$alert["alertTime"]</strong>
-                                </td>
-                            </tr>
-                                <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                    <td class="content-block"
-                                        style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0 4px; padding: 10px 10px; background-color: #eee;"
-                                        valign="top">
-                                        <div style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif;  box-sizing: border-box; font-size: 14px; vertical-align: top;">
-                                            $alert["alertBody"]
-                                        </div>
-                                    </td>
-                                </tr>
-
-                                <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                    <td class="content-block aligncenter"
-                                        style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; text-align: center; margin: 0; padding: 0 0 10px;"
-                                        align="center" valign="top">
-                                        <table class="invoice"
-                                               style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; text-align: left; width: 90%; margin: 10px auto;">
-                                            <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                                <td style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0; padding: 5px 0;"
-                                                    valign="top">
-                                                    <table class="invoice-items" cellpadding="0" cellspacing="0"
-                                                           style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; width: 100%; margin: 0;">
-                                                        <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                                            <td style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0; padding: 5px 0;"
-                                                                valign="top">
-                                                                Severity
-                                                            </td>
-                                                            <td style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0; padding: 5px 0;"
-                                                                valign="top"> $alert["alertSeverity"]
-                                                            </td>
-                                                        </tr>
-                                                        <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                                            <td style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; border-top-width: 1px; border-top-color: #eee; border-top-style: solid; margin: 0; padding: 5px 0;"
-                                                                valign="top">Category
-                                                            </td>
-                                                            <td class="alignright"
-                                                                style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; text-align: left; border-top-width: 1px; border-top-color: #eee; border-top-style: solid; margin: 0; padding: 5px 0;"
-                                                                align="right" valign="top">
-                                                                #if($alert["alertCategory"])
-                                                                    $alert["alertCategory"]
-                                                                #else
-                                                                    N/A
-                                                                #end
-                                                            </td>
-                                                        </tr>
-                                                        <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                                            <td style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; border-top-width: 1px; border-top-color: #eee; border-top-style: solid; margin: 0; padding: 5px 0;"
-                                                                valign="top">Cluster
-                                                            </td>
-                                                            <td class="alignright"
-                                                                style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; text-align: left; border-top-width: 1px; border-top-color: #eee; border-top-style: solid; margin: 0; padding: 5px 0;"
-                                                                align="right" valign="top">$alert["siteId"]
-                                                            </td>
-                                                        </tr>
-                                                        <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                                            <td style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; border-top-width: 1px; border-top-color: #eee; border-top-style: solid; margin: 0; padding: 5px 0;"
-                                                                valign="top">Policy
-                                                            </td>
-                                                            <td class="alignright"
-                                                                style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; text-align: left; border-top-width: 1px; border-top-color: #eee; border-top-style: solid; margin: 0; padding: 5px 0;"
-                                                                align="right" valign="top"><a
-                                                                    href="$alert["policyDetailUrl"]"
-                                                                    style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; color: #999; text-decoration: underline; margin: 0;">$alert[
-                                                                "policyId"]</a>
-                                                            </td>
-                                                        </tr>
-                                                    </table>
-                                                </td>
-                                            </tr>
-                                        </table>
-                                    </td>
-                                </tr>
-
-                                <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                                    <td class="content-block"
-                                        style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0; padding: 0 0 20px;"
-                                        valign="top">
-                                        <a href="$alert["alertDetailUrl"]" class="btn-primary"
-                                           style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; color: #FFF; text-decoration: none; line-height: 2em; font-weight: bold; text-align: center; cursor: pointer; display: inline-block; border-radius: 5px; text-transform: capitalize; background-color: $alertColor; margin: 0; border-color: $alertColor; border-style: solid; border-width: 10px 20px;">
-                                            View Alert Details
-                                        </a>
-                                    </td>
-                                </tr>
-                            </table>
-                        </td>
-                    </tr>
-                </table>
-                <div class="footer"
-                     style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; width: 100%; clear: both; color: #999; margin: 0; padding: 20px;">
-                    <table width="100%"
-                           style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                        <tr style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; margin: 0;">
-                            <td class="aligncenter content-block"
-                                style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 12px; vertical-align: top; color: #999; text-align: center; margin: 0; padding: 0 0 20px;"
-                                align="center" valign="top">
-                                Powered by <a href="http://eagle.incubator.apache.org"
-                                              style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 12px; color: #999; text-decoration: underline; margin: 0;">Apache
-                                Eagle</a> (version: $alert["version"])
-                            </td>
-                        </tr>
-                    </table>
-                </div>
-            </div>
-        </td>
-        <td style="font-family: 'Helvetica Neue',Helvetica,Arial,sans-serif; box-sizing: border-box; font-size: 14px; vertical-align: top; margin: 0;"
-            valign="top"></td>
-    </tr>
-</table>
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_LIGHT_TEMPLATE.vm
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_LIGHT_TEMPLATE.vm b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_LIGHT_TEMPLATE.vm
deleted file mode 100644
index f273917..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/resources/ALERT_LIGHT_TEMPLATE.vm
+++ /dev/null
@@ -1,495 +0,0 @@
-<!--
-  ~ Licensed to the Apache Software Foundation (ASF) under one or more
-  ~ contributor license agreements.  See the NOTICE file distributed with
-  ~ this work for additional information regarding copyright ownership.
-  ~ The ASF licenses this file to You under the Apache License, Version 2.0
-  ~ (the "License"); you may not use this file except in compliance with
-  ~ the License.  You may obtain a copy of the License at
-  ~
-  ~    http://www.apache.org/licenses/LICENSE-2.0
-  ~
-  ~ Unless required by applicable law or agreed to in writing, software
-  ~ distributed under the License is distributed on an "AS IS" BASIS,
-  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  ~ See the License for the specific language governing permissions and
-  ~ limitations under the License.
-  -->
-<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
-<html xmlns="http://www.w3.org/1999/xhtml">
-
-    #set ( $alert = $alertList[0] )
-<head>
-    <meta name="viewport" content="width=device-width" />
-    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
-    <title>[$alert["alertSeverity"]$alert["alertSubject"]</title>
-    <style rel="stylesheet" type="text/css">
-        /* -------------------------------------
-            GLOBAL
-            A very basic CSS reset
-        ------------------------------------- */
-        * {
-            margin: 0;
-            font-family: "Helvetica Neue", Helvetica, Arial, sans-serif;
-            box-sizing: border-box;
-            font-size: 14px;
-        }
-
-        img {
-            max-width: 100%;
-        }
-
-        body {
-            -webkit-font-smoothing: antialiased;
-            -webkit-text-size-adjust: none;
-            width: 100% !important;
-            height: 100%;
-            line-height: 1.6em;
-            /* 1.6em * 14px = 22.4px, use px to get airier line-height also in Thunderbird, and Yahoo!, Outlook.com, AOL webmail clients */
-            /*line-height: 22px;*/
-        }
-
-        /* Let's make sure all tables have defaults */
-        table td {
-            vertical-align: top;
-        }
-
-        /* -------------------------------------
-            BODY & CONTAINER
-        ------------------------------------- */
-        body {
-            background-color: #f6f6f6;
-        }
-
-        .body-wrap {
-            background-color: #f6f6f6;
-            width: 100%;
-        }
-
-        .container {
-            display: block !important;
-            max-width: 600px !important;
-            margin: 0 auto !important;
-            /* makes it centered */
-            clear: both !important;
-        }
-
-        .content {
-            max-width: 600px;
-            margin: 0 auto;
-            display: block;
-            padding: 20px;
-        }
-
-        /* -------------------------------------
-            HEADER, FOOTER, MAIN
-        ------------------------------------- */
-        .main {
-            background-color: #fff;
-            border: 1px solid #e9e9e9;
-            border-radius: 3px;
-        }
-
-        .content-wrap {
-            padding: 20px;
-        }
-
-        .content-block {
-            padding: 0 0 20px;
-        }
-
-        .header {
-            width: 100%;
-            margin-bottom: 20px;
-        }
-
-        .footer {
-            width: 100%;
-            clear: both;
-            color: #999;
-            padding: 20px;
-        }
-        .footer p, .footer a, .footer td {
-            color: #999;
-            font-size: 12px;
-        }
-
-        /* -------------------------------------
-            TYPOGRAPHY
-        ------------------------------------- */
-        h1, h2, h3 {
-            font-family: "Helvetica Neue", Helvetica, Arial, "Lucida Grande", sans-serif;
-            color: #000;
-            margin: 40px 0 0;
-            line-height: 1.2em;
-            font-weight: 400;
-        }
-
-        h1 {
-            font-size: 32px;
-            font-weight: 500;
-            /* 1.2em * 32px = 38.4px, use px to get airier line-height also in Thunderbird, and Yahoo!, Outlook.com, AOL webmail clients */
-            /*line-height: 38px;*/
-        }
-
-        h2 {
-            font-size: 24px;
-            /* 1.2em * 24px = 28.8px, use px to get airier line-height also in Thunderbird, and Yahoo!, Outlook.com, AOL webmail clients */
-            /*line-height: 29px;*/
-        }
-
-        h3 {
-            font-size: 18px;
-            /* 1.2em * 18px = 21.6px, use px to get airier line-height also in Thunderbird, and Yahoo!, Outlook.com, AOL webmail clients */
-            /*line-height: 22px;*/
-        }
-
-        h4 {
-            font-size: 14px;
-            font-weight: 600;
-        }
-
-        p, ul, ol {
-            margin-bottom: 10px;
-            font-weight: normal;
-        }
-        p li, ul li, ol li {
-            margin-left: 5px;
-            list-style-position: inside;
-        }
-
-
-        /* -------------------------------------
-            LINKS & BUTTONS
-        ------------------------------------- */
-        a {
-            color: #348eda;
-            text-decoration: underline;
-        }
-
-        .btn-primary {
-            text-decoration: none;
-            color: #FFF;
-            background-color: #348eda;
-            border: solid #348eda;
-            border-width: 10px 20px;
-            line-height: 2em;
-            /* 2em * 14px = 28px, use px to get airier line-height also in Thunderbird, and Yahoo!, Outlook.com, AOL webmail clients */
-            /*line-height: 28px;*/
-            font-weight: bold;
-            text-align: center;
-            cursor: pointer;
-            display: inline-block;
-            border-radius: 5px;
-            text-transform: capitalize;
-        }
-
-        .btn-warning {
-            text-decoration: none;
-            color: #FFF;
-            background-color: #f0ad4e;
-            border-color: solid #eea236;
-            /*background-color: #348eda;*/
-            /*border: solid #348eda;*/
-            border-width: 10px 20px;
-            line-height: 2em;
-            /* 2em * 14px = 28px, use px to get airier line-height also in Thunderbird, and Yahoo!, Outlook.com, AOL webmail clients */
-            /*line-height: 28px;*/
-            font-weight: bold;
-            text-align: center;
-            cursor: pointer;
-            display: inline-block;
-            border-radius: 5px;
-            text-transform: capitalize;
-        }
-
-        .btn-danger {
-            text-decoration: none;
-            color: #fff;
-            background-color: #d9534f;
-            border-color: solid #d43f3a;
-            /*color: #FFF;*/
-            /*background-color: #348eda;*/
-            /*border: solid #348eda;*/
-            border-width: 10px 20px;
-            line-height: 2em;
-            /* 2em * 14px = 28px, use px to get airier line-height also in Thunderbird, and Yahoo!, Outlook.com, AOL webmail clients */
-            /*line-height: 28px;*/
-            font-weight: bold;
-            text-align: center;
-            cursor: pointer;
-            display: inline-block;
-            border-radius: 5px;
-            text-transform: capitalize;
-        }
-
-        .text-light {
-            color: #eee;
-        }
-
-        .text-primary {
-            color: #348eda;
-        }
-
-        .text-warning {
-            color: #eea236
-        }
-
-        .text-danger {
-            color: #d43f3a;
-        }
-
-        .label {
-            display: inline;
-            padding: .2em .6em .3em;
-            font-size: 75%;
-            font-weight: 700;
-            line-height: 1;
-            color: #fff;
-            text-align: center;
-            white-space: nowrap;
-            vertical-align: baseline;
-            border-radius: .25em;
-        }
-
-        .label-ok {
-            background-color: #777;
-        }
-        .label-default {
-            background-color: #777;
-        }
-        .label-primary {
-            background-color: #337ab7;
-        }
-        .label-critical {
-            background-color: #d9534f;
-        }
-        .label-warning {
-            background-color: #f0ad4e;
-        }
-
-        /* -------------------------------------
-            OTHER STYLES THAT MIGHT BE USEFUL
-        ------------------------------------- */
-        .last {
-            margin-bottom: 0;
-        }
-
-        .first {
-            margin-top: 0;
-        }
-
-        .aligncenter {
-            text-align: center;
-        }
-
-        .alignright {
-            text-align: right;
-        }
-
-        .alignleft {
-            text-align: left;
-        }
-
-        .clear {
-            clear: both;
-        }
-
-        /* -------------------------------------
-            ALERTS
-            Change the class depending on warning email, good email or bad email
-        ------------------------------------- */
-        .alert {
-            font-size: 16px;
-            color: #fff;
-            font-weight: 500;
-            padding: 20px;
-            text-align: center;
-            border-radius: 3px 3px 0 0;
-        }
-        .alert a {
-            color: #fff;
-            text-decoration: none;
-            font-weight: 500;
-            font-size: 16px;
-        }
-        .alert.alert-warning {
-            background-color: #FF9F00;
-        }
-        .alert.alert-bad {
-            background-color: #D0021B;
-        }
-        .alert.alert-critical {
-            background-color: #D0021B;
-        }
-        .alert.alert-fetal {
-            background-color: #D0021B;
-        }
-        .alert.alert-ok {
-            background-color: #68B90F;
-        }
-
-        .alert-body {
-            margin-bottom: 10px;
-            padding: 8px;
-            background-color: #fff;
-            border: 1px solid transparent;
-            border-radius: 4px;
-            -webkit-box-shadow: 0 1px 1px rgba(0,0,0,.05);
-            box-shadow: 0 1px 1px rgba(0,0,0,.05);
-        }
-        .alert-body-default {
-            border-color: #eee;
-        }
-        .alert-body-primary {
-            border-color: #337ab7;
-        }
-        .alert-body-warning {
-            border-color: #faebcc;
-        }
-        .alert-body-danger {
-            border-color: #ebccd1;
-        }
-        /* -------------------------------------
-            INVOICE
-            Styles for the billing table
-        ------------------------------------- */
-        .invoice {
-            margin: 40px auto;
-            text-align: left;
-            width: 80%;
-        }
-        .invoice td {
-            padding: 5px 0;
-        }
-        .invoice .invoice-items {
-            width: 100%;
-        }
-        .invoice .invoice-items td {
-            border-bottom: #eee 1px solid;
-        }
-        .invoice .invoice-items .total td {
-            border-top: 2px solid #333;
-            border-bottom: 2px solid #333;
-            font-weight: 700;
-        }
-
-        /* -------------------------------------
-            RESPONSIVE AND MOBILE FRIENDLY STYLES
-        ------------------------------------- */
-        @media only screen and (max-width: 640px) {
-            body {
-                padding: 0 !important;
-            }
-            h1, h2, h3, h4 {
-                font-weight: 800 !important;
-                margin: 20px 0 5px !important;
-            }
-            h1 {
-                font-size: 22px !important;
-            }
-
-            h2 {
-                font-size: 18px !important;
-            }
-            h3 {
-                font-size: 16px !important;
-            }
-            .container {
-                padding: 0 !important;
-                width: 100% !important;
-            }
-            .content {
-                padding: 0 !important;
-            }
-            .content-wrap {
-                padding: 10px !important;
-            }
-            .invoice {
-                width: 100% !important;
-            }
-        }
-        /*# sourceMappingURL=styles.css.map */
-    </style>
-</head>
-
-<body itemscope itemtype="http://schema.org/EmailMessage">
-
-<table class="body-wrap">
-    <tr>
-        <td></td>
-        <td class="container" width="600">
-            <div class="content">
-                <table class="main" width="100%" cellpadding="0" cellspacing="0">
-                    <tr>
-                        <td class="alert alert-$alert["alertSeverity"].toLowerCase()">
-                            <strong>$alert["alertSeverity"]</strong> $alert["alertSubject"]
-                        </td>
-                    </tr>
-                    <tr>
-                        <td class="content-wrap">
-                            <table width="100%" cellpadding="0" cellspacing="0">
-                                <tr>
-                                    <td class="content-block">
-                                        <table>
-                                            <tbody>
-                                                <tr>
-                                                    <td>Category:</td>
-                                                    <td><strong>$alert["alertCategory"]</strong></td>
-                                                    <td>Time:</td>
-                                                    <td><strong>$alert["alertTime"]</strong></td>
-                                                </tr>
-                                            </tbody>
-                                        </table>
-                                    </td>
-                                </tr>
-                                <tr>
-                                    <td class="content-block">
-                                        <div class="alert-body alert-body-default">
-                                        $alert["alertBody"]
-                                        </div>
-                                    </td>
-                                </tr>
-                                <tr>
-                                    <td class="content-block invoice">
-                                        <table class="invoice-items" cellpadding="0" cellspacing="0">
-                                            <tbody>
-                                                <tr>
-                                                    <td>Cluster</td>
-                                                    <td>$alert["siteId"]</td>
-                                                </tr>
-                                                <tr>
-                                                    <td>Policy</td>
-                                                    <td><a href="$alert["policyDetailUrl"]">$alert["policyId"]</a></td>
-                                                </tr>
-                                            </tbody>
-                                        </table>
-                                    </td>
-                                </tr>
-                                <tr>
-                                    <td class="content-block">
-                                        <a href="$alert["alertDetailUrl"]" class="btn-primary">View Alert Details</a>
-                                    </td>
-                                </tr>
-                                <tr>
-                                    <td class="content-block">
-                                        <i>Note: The alert was automatically detected by <a href="#">Eagle</a>.</i>
-                                    </td>
-                                </tr>
-                            </table>
-                        </td>
-                    </tr>
-                </table>
-                <div class="footer">
-                    <table width="100%">
-                        <tr>
-                            <td class="aligncenter content-block">Powered by <a href="http://eagle.apache.org">Apache Eagle</a> (version: $alert["version"])</td>
-                        </tr>
-                    </table>
-                </div>
-            </div>
-        </td>
-        <td></td>
-    </tr>
-</table>
-</body>
-</html>


Mime
View raw message