ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dmitriu...@apache.org
Subject [1/2] ambari git commit: AMBARI-12984. Alert from Ambari when cluster not finalized after HDFS upgrade (dgrinenko via dlysnichenko)
Date Thu, 03 Sep 2015 10:45:32 GMT
Repository: ambari
Updated Branches:
  refs/heads/branch-2.1 fd324ac14 -> 533e30684
  refs/heads/trunk fbbd684e6 -> 61098026b


AMBARI-12984. Alert from Ambari when cluster not finalized after HDFS upgrade (dgrinenko via
dlysnichenko)


Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/533e3068
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/533e3068
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/533e3068

Branch: refs/heads/branch-2.1
Commit: 533e30684412cdfadd144cb79d6d8f71af9f97c4
Parents: fd324ac
Author: Lisnichenko Dmitro <dlysnichenko@hortonworks.com>
Authored: Thu Sep 3 13:44:24 2015 +0300
Committer: Lisnichenko Dmitro <dlysnichenko@hortonworks.com>
Committed: Thu Sep 3 13:44:24 2015 +0300

----------------------------------------------------------------------
 .../HDFSUpgradeFinalizedStatusRunnable.java     | 215 ++++++++++++++
 ambari-server/src/main/resources/alerts.json    |  14 +-
 .../HDFSUpgradeFinalizedStatusRunnableTest.java | 294 +++++++++++++++++++
 3 files changed, 522 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/533e3068/ambari-server/src/main/java/org/apache/ambari/server/alerts/HDFSUpgradeFinalizedStatusRunnable.java
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/java/org/apache/ambari/server/alerts/HDFSUpgradeFinalizedStatusRunnable.java
b/ambari-server/src/main/java/org/apache/ambari/server/alerts/HDFSUpgradeFinalizedStatusRunnable.java
new file mode 100644
index 0000000..b5da9df
--- /dev/null
+++ b/ambari-server/src/main/java/org/apache/ambari/server/alerts/HDFSUpgradeFinalizedStatusRunnable.java
@@ -0,0 +1,215 @@
+/**
+ * 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.ambari.server.alerts;
+
+import com.google.inject.Inject;
+import com.google.inject.Provider;
+import org.apache.ambari.server.AmbariException;
+import org.apache.ambari.server.ServiceNotFoundException;
+import org.apache.ambari.server.controller.internal.ComponentResourceProvider;
+import org.apache.ambari.server.controller.spi.NoSuchParentResourceException;
+import org.apache.ambari.server.controller.spi.NoSuchResourceException;
+import org.apache.ambari.server.controller.spi.Predicate;
+import org.apache.ambari.server.controller.spi.Request;
+import org.apache.ambari.server.controller.spi.Resource;
+import org.apache.ambari.server.controller.spi.SystemException;
+import org.apache.ambari.server.controller.spi.UnsupportedPropertyException;
+import org.apache.ambari.server.controller.utilities.ClusterControllerHelper;
+import org.apache.ambari.server.controller.utilities.PredicateBuilder;
+import org.apache.ambari.server.controller.utilities.PropertyHelper;
+import org.apache.ambari.server.events.AlertEvent;
+import org.apache.ambari.server.events.AlertReceivedEvent;
+import org.apache.ambari.server.events.publishers.AlertEventPublisher;
+import org.apache.ambari.server.orm.dao.AlertDefinitionDAO;
+import org.apache.ambari.server.orm.entities.AlertDefinitionEntity;
+import org.apache.ambari.server.state.Alert;
+import org.apache.ambari.server.state.AlertState;
+import org.apache.ambari.server.state.Cluster;
+import org.apache.ambari.server.state.Clusters;
+import org.apache.ambari.server.state.services.AmbariServerAlertService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Date;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * The {@link HDFSUpgradeFinalizedStatusRunnable} is used by the
+ * {@link AmbariServerAlertService} to check hdfs finalized status
+ */
+public class HDFSUpgradeFinalizedStatusRunnable implements Runnable
+{
+  /**
+   * Logger.
+   */
+  private final static Logger LOG = LoggerFactory.getLogger(AgentHeartbeatAlertRunnable.class);
+  /**
+   * String constants
+   */
+  private final static String s_serviceName = "HDFS";
+  private final static String s_serviceComponent = "NAMENODE";
+  private final static String s_upgradeFinalizedMetricProperty = "UpgradeFinalized";
+  private final static String s_alertText = "HDFS cluster is not in the upgrade state";
+  private final static String s_alertCriticalText = "HDFS cluster is not finalized";
+  private final static String s_alertUnknownText = "HDFS cluster is in the unknown state";
+  /**
+   * The unique name for the alert definition that governs this service.
+   */
+  private static final String ALERT_DEFINITION_NAME = "ambari_upgrade_finalized_state";
+  /**
+   * Used for looking up alert definitions.
+   */
+  @Inject
+  private AlertDefinitionDAO m_dao;
+  /**
+   * Used to get alert definitions to use when generating alert instances.
+   */
+  @Inject
+  private Provider<Clusters> m_clustersProvider;
+  /**
+   * Publishes {@link AlertEvent} instances.
+   */
+  @Inject
+  private AlertEventPublisher m_alertEventPublisher;
+
+  /**
+   * Represent possibly HDFS upgrade finalization states
+   */
+  private enum HDFSFinalizationState {
+    /**
+     * HDFS is not in the upgrade state
+     */
+    FINALIZED,
+    /**
+     * HDFS currently in the upgrade state
+     */
+    NOT_FINALIZED,
+    /**
+     * Undetermined stated, probably service is turned off and no metric available
+     */
+    UNKNOWN
+  }
+
+  public HDFSUpgradeFinalizedStatusRunnable(){
+  }
+
+  @Override
+  public void run(){
+    try {
+      Map<String, Cluster> clusterMap = m_clustersProvider.get().getClusters();
+
+      for (Cluster cluster : clusterMap.values()) {
+        AlertDefinitionEntity entity = m_dao.findByName(cluster.getClusterId(), ALERT_DEFINITION_NAME);
+
+        // skip this cluster if the runnable's alert definition is missing or disabled
+        if (null == entity || !entity.getEnabled()) {
+          continue;
+        }
+
+        // check if the service existed
+        try {
+          cluster.getService(s_serviceName);
+        } catch (ServiceNotFoundException e){
+          continue;
+        }
+
+        Date current = new Date(System.currentTimeMillis());
+        HDFSFinalizationState upgradeFinalized = getUpgradeFinalizedProperty(cluster);
+
+        AlertState alertState;
+        String alertDescription;
+
+        if (upgradeFinalized == HDFSFinalizationState.UNKNOWN) {
+          alertState = AlertState.UNKNOWN;
+          alertDescription = s_alertUnknownText;
+        } else if (upgradeFinalized == HDFSFinalizationState.FINALIZED){
+          alertState = AlertState.OK;
+          alertDescription = s_alertText;
+        } else {
+          alertState = AlertState.CRITICAL;
+          alertDescription = s_alertCriticalText;
+        }
+
+        Alert alert = new Alert(entity.getDefinitionName(), null,
+          entity.getServiceName(), entity.getComponentName(), null, alertState);
+
+        alert.setLabel(entity.getLabel());
+        alert.setText(alertDescription);
+        alert.setTimestamp(current.getTime());
+        alert.setCluster(cluster.getClusterName());
+        AlertReceivedEvent event = new AlertReceivedEvent(cluster.getClusterId(), alert);
+        m_alertEventPublisher.publish(event);
+      }
+    } catch (Exception e){
+      LOG.error("Unable to run the {} alert", ALERT_DEFINITION_NAME, e);
+    }
+  }
+
+  /**
+   * Query {@link ComponentResourceProvider} for the HDFS finalization status
+   * @param cluster the cluster for the query
+   * @return HDFS finalization status flag
+   * @throws AmbariException
+   */
+  private HDFSFinalizationState getUpgradeFinalizedProperty(Cluster cluster) throws AmbariException{
+  try
+    {
+      ComponentResourceProvider crp = (ComponentResourceProvider) ClusterControllerHelper
+        .getClusterController().ensureResourceProvider(Resource.Type.Component);
+
+      Set<String> properties = new HashSet<String>();
+      properties.add("ServiceComponentInfo/" + s_upgradeFinalizedMetricProperty);
+      Request request = PropertyHelper.getReadRequest(properties);
+      PredicateBuilder pb = new PredicateBuilder();
+
+      Predicate predicate =  pb.begin()
+        .property("ServiceComponentInfo/service_name").equals(s_serviceName)
+        .and()
+        .property("ServiceComponentInfo/component_name").equals(s_serviceComponent)
+        .and()
+        .property("ServiceComponentInfo/cluster_name").equals(cluster.getClusterName())
+        .end().toPredicate();
+
+      Set<Resource> res =  ClusterControllerHelper.getClusterController().populateResources(
+                   Resource.Type.Component,
+                   crp.getResources(request, predicate),
+                   request,
+                   predicate);
+
+      for (Resource rr: res){
+        for (Map<String, Object> t: rr.getPropertiesMap().values()){
+          if (t.containsKey(s_upgradeFinalizedMetricProperty) &&
+              t.get(s_upgradeFinalizedMetricProperty) instanceof Boolean) {
+
+            if ((Boolean)t.get(s_upgradeFinalizedMetricProperty)){
+              return HDFSFinalizationState.FINALIZED;
+            } else {
+              return HDFSFinalizationState.NOT_FINALIZED;
+            }
+          }
+        }
+      }
+    } catch (SystemException|UnsupportedPropertyException|NoSuchParentResourceException|NoSuchResourceException
e) {
+      LOG.error("Unable to run the {} alert", ALERT_DEFINITION_NAME, e);
+    }
+    // no metric available
+    return HDFSFinalizationState.UNKNOWN;
+  }
+}

http://git-wip-us.apache.org/repos/asf/ambari/blob/533e3068/ambari-server/src/main/resources/alerts.json
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/alerts.json b/ambari-server/src/main/resources/alerts.json
index a7cef7f..1285b24 100644
--- a/ambari-server/src/main/resources/alerts.json
+++ b/ambari-server/src/main/resources/alerts.json
@@ -26,7 +26,19 @@
           "type": "SERVER",
           "class": "org.apache.ambari.server.alerts.StaleAlertRunnable"
         }
-      }      
+      },
+      {
+        "name": "ambari_upgrade_finalized_state",
+        "label": "HDFS Upgrade Finalized State",
+        "description": "This service-level alert is triggered if HDFS is not in the finalized
state",
+        "interval": 10,
+        "scope": "SERVICE",
+        "enabled": true,
+        "source": {
+          "type": "SERVER",
+          "class": "org.apache.ambari.server.alerts.HDFSUpgradeFinalizedStatusRunnable"
+        }
+      }
     ],
     "AMBARI_AGENT" : [
       {

http://git-wip-us.apache.org/repos/asf/ambari/blob/533e3068/ambari-server/src/test/java/org/apache/ambari/server/alerts/HDFSUpgradeFinalizedStatusRunnableTest.java
----------------------------------------------------------------------
diff --git a/ambari-server/src/test/java/org/apache/ambari/server/alerts/HDFSUpgradeFinalizedStatusRunnableTest.java
b/ambari-server/src/test/java/org/apache/ambari/server/alerts/HDFSUpgradeFinalizedStatusRunnableTest.java
new file mode 100644
index 0000000..df9834f
--- /dev/null
+++ b/ambari-server/src/test/java/org/apache/ambari/server/alerts/HDFSUpgradeFinalizedStatusRunnableTest.java
@@ -0,0 +1,294 @@
+/**
+ * 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.ambari.server.alerts;
+
+import static junit.framework.Assert.assertEquals;
+import static org.easymock.EasyMock.anyObject;
+import static org.easymock.EasyMock.createNiceMock;
+import static org.easymock.EasyMock.expect;
+import static org.easymock.EasyMock.replay;
+import static org.easymock.EasyMock.verify;
+
+import java.lang.reflect.Field;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import javax.persistence.EntityManager;
+
+import org.apache.ambari.server.controller.internal.ComponentResourceProvider;
+import org.apache.ambari.server.controller.internal.ResourceImpl;
+import org.apache.ambari.server.controller.spi.ClusterController;
+import org.apache.ambari.server.controller.spi.Predicate;
+import org.apache.ambari.server.controller.spi.Request;
+import org.apache.ambari.server.controller.spi.Resource;
+import org.apache.ambari.server.controller.spi.SystemException;
+import org.apache.ambari.server.controller.utilities.ClusterControllerHelper;
+import org.apache.ambari.server.events.AlertEvent;
+import org.apache.ambari.server.events.AlertReceivedEvent;
+import org.apache.ambari.server.events.MockEventListener;
+import org.apache.ambari.server.events.publishers.AlertEventPublisher;
+import org.apache.ambari.server.orm.DBAccessor;
+import org.apache.ambari.server.orm.dao.AlertDefinitionDAO;
+import org.apache.ambari.server.orm.dao.AlertsDAO;
+import org.apache.ambari.server.orm.entities.AlertCurrentEntity;
+import org.apache.ambari.server.orm.entities.AlertDefinitionEntity;
+import org.apache.ambari.server.state.Alert;
+import org.apache.ambari.server.state.AlertState;
+import org.apache.ambari.server.state.Cluster;
+import org.apache.ambari.server.state.Clusters;
+import org.apache.ambari.server.state.stack.OsFamily;
+import org.easymock.EasyMock;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+import com.google.common.eventbus.EventBus;
+import com.google.inject.Binder;
+import com.google.inject.Guice;
+import com.google.inject.Injector;
+import com.google.inject.Module;
+import org.junit.runner.RunWith;
+import org.powermock.api.easymock.PowerMock;
+import org.powermock.core.classloader.annotations.PrepareForTest;
+import org.powermock.modules.junit4.PowerMockRunner;
+
+/**
+ * Tests {@link StaleAlertRunnableTest}.
+ */
+@RunWith(PowerMockRunner.class)
+@PrepareForTest(ClusterControllerHelper.class)
+public class HDFSUpgradeFinalizedStatusRunnableTest {
+
+  private final static long CLUSTER_ID = 1;
+  private final static String CLUSTER_NAME = "c1";
+
+  private final static String DEFINITION_NAME = "ambari_upgrade_finalized_state";
+  private final static String DEFINITION_SERVICE = "AMBARI";
+  private final static String DEFINITION_COMPONENT = "AMBARI_SERVER";
+  private final static String DEFINITION_LABEL = "Mock Definition";
+  private final static String s_upgradeFinalizedMetricProperty = "UpgradeFinalized";
+  private final static int DEFINITION_INTERVAL = 1;
+
+  private Clusters m_clusters;
+  private Cluster m_cluster;
+  private Injector m_injector;
+  private AlertsDAO m_alertsDao;
+  private AlertDefinitionDAO m_definitionDao;
+  private AlertDefinitionEntity m_definition;
+  private List<AlertCurrentEntity> m_currentAlerts = new ArrayList<AlertCurrentEntity>();
+  private MockEventListener m_listener;
+
+  private AlertEventPublisher m_eventPublisher;
+  private EventBus m_synchronizedBus;
+
+  /**
+   *
+   */
+  @Before
+  public void setup() throws Exception {
+    m_injector = Guice.createInjector(new MockModule());
+    m_alertsDao = m_injector.getInstance(AlertsDAO.class);
+    m_definitionDao = m_injector.getInstance(AlertDefinitionDAO.class);
+    m_clusters = m_injector.getInstance(Clusters.class);
+    m_cluster = m_injector.getInstance(Cluster.class);
+    m_eventPublisher = m_injector.getInstance(AlertEventPublisher.class);
+    m_listener = m_injector.getInstance(MockEventListener.class);
+    m_definition = EasyMock.createNiceMock(AlertDefinitionEntity.class);
+
+    // !!! need a synchronous op for testing
+    m_synchronizedBus = new EventBus();
+    Field field = AlertEventPublisher.class.getDeclaredField("m_eventBus");
+    field.setAccessible(true);
+    field.set(m_eventPublisher, m_synchronizedBus);
+
+    // register mock listener
+    m_synchronizedBus.register(m_listener);
+
+    // create the cluster map
+    Map<String,Cluster> clusterMap = new HashMap<String, Cluster>();
+    clusterMap.put(CLUSTER_NAME, m_cluster);
+
+    // mock the definition for the alert
+    expect(m_definition.getDefinitionName()).andReturn(DEFINITION_NAME).atLeastOnce();
+    expect(m_definition.getServiceName()).andReturn(DEFINITION_SERVICE).atLeastOnce();
+    expect(m_definition.getComponentName()).andReturn(DEFINITION_COMPONENT).atLeastOnce();
+    expect(m_definition.getLabel()).andReturn(DEFINITION_LABEL).atLeastOnce();
+    expect(m_definition.getEnabled()).andReturn(true).atLeastOnce();
+    expect(m_definition.getScheduleInterval()).andReturn(DEFINITION_INTERVAL).atLeastOnce();
+
+    // mock the cluster
+    expect(m_cluster.getClusterId()).andReturn(CLUSTER_ID).atLeastOnce();
+
+    // mock clusters
+    expect(m_clusters.getClusters()).andReturn(clusterMap).atLeastOnce();
+
+    // mock the definition DAO
+    expect(m_definitionDao.findByName(CLUSTER_ID, DEFINITION_NAME)).andReturn(
+      m_definition).atLeastOnce();
+
+    // mock the current dao
+    expect(m_alertsDao.findCurrentByCluster(CLUSTER_ID)).andReturn(
+      m_currentAlerts).atLeastOnce();
+
+    replay(m_definition, m_cluster, m_clusters,
+      m_definitionDao, m_alertsDao);
+  }
+
+  /**
+   * @throws Exception
+   */
+  @After
+  public void teardown() throws Exception {
+  }
+
+  /**
+   * Tests that the event is triggered with a status of OK.
+   */
+  @Test
+  @SuppressWarnings("unchecked")
+  public void testFinalizedState() throws SystemException {
+
+    // create current alerts that are not stale
+    Resource resource = new ResourceImpl(Resource.Type.Component);
+    resource.setProperty(s_upgradeFinalizedMetricProperty, Boolean.TRUE);
+
+    ClusterController clusterController = createNiceMock(ClusterController.class);
+    ComponentResourceProvider crp = createNiceMock(ComponentResourceProvider.class);
+
+
+    Set<Resource> resourceMap = new HashSet<Resource>();
+    resourceMap.add(resource);
+
+    PowerMock.mockStatic(ClusterControllerHelper.class);
+    expect(ClusterControllerHelper.getClusterController()).andReturn(clusterController).atLeastOnce();
+    expect(clusterController.ensureResourceProvider(anyObject(Resource.Type.class))).andReturn(crp).atLeastOnce();
+    expect(clusterController.populateResources(anyObject(Resource.Type.class),
+      anyObject(resourceMap.getClass()), anyObject(Request.class), anyObject(Predicate.class))).andReturn(resourceMap).atLeastOnce();
+
+    PowerMock.replay(ClusterControllerHelper.class);
+    replay(crp, clusterController);
+
+
+    // precondition that no events were fired
+    assertEquals(0,
+      m_listener.getAlertEventReceivedCount(AlertReceivedEvent.class));
+
+    // instantiate and inject mocks
+    HDFSUpgradeFinalizedStatusRunnable runnable = new HDFSUpgradeFinalizedStatusRunnable();
+    m_injector.injectMembers(runnable);
+
+    // run the alert
+    runnable.run();
+
+    assertEquals(1,
+      m_listener.getAlertEventReceivedCount(AlertReceivedEvent.class));
+
+    List<AlertEvent> events = m_listener.getAlertEventInstances(AlertReceivedEvent.class);
+    assertEquals(1, events.size());
+
+    AlertReceivedEvent event = (AlertReceivedEvent) events.get(0);
+    Alert alert = event.getAlert();
+    assertEquals("AMBARI", alert.getService());
+    assertEquals("AMBARI_SERVER", alert.getComponent());
+    assertEquals(AlertState.OK, alert.getState());
+    assertEquals(DEFINITION_NAME, alert.getName());
+
+    verify(m_cluster, m_clusters, m_definitionDao);
+  }
+
+  /**
+   * Tests that a alert triggers the event with a status of CRITICAL.
+   */
+  @Test
+  @SuppressWarnings("unchecked")
+  public void testNonFinalizedState() throws SystemException {
+
+    // create current alerts that are not stale
+    Resource resource = new ResourceImpl(Resource.Type.Component);
+    resource.setProperty(s_upgradeFinalizedMetricProperty, Boolean.FALSE);
+
+    ClusterController clusterController = createNiceMock(ClusterController.class);
+    ComponentResourceProvider crp = createNiceMock(ComponentResourceProvider.class);
+
+
+    Set<Resource> resourceMap = new HashSet<Resource>();
+    resourceMap.add(resource);
+
+    PowerMock.mockStatic(ClusterControllerHelper.class);
+    expect(ClusterControllerHelper.getClusterController()).andReturn(clusterController).atLeastOnce();
+    expect(clusterController.ensureResourceProvider(anyObject(Resource.Type.class))).andReturn(crp).atLeastOnce();
+    expect(clusterController.populateResources(anyObject(Resource.Type.class),
+      anyObject(resourceMap.getClass()), anyObject(Request.class), anyObject(Predicate.class))).andReturn(resourceMap).atLeastOnce();
+
+    PowerMock.replay(ClusterControllerHelper.class);
+    replay(crp, clusterController);
+
+
+    // precondition that no events were fired
+    assertEquals(0,
+      m_listener.getAlertEventReceivedCount(AlertReceivedEvent.class));
+
+    // instantiate and inject mocks
+    HDFSUpgradeFinalizedStatusRunnable runnable = new HDFSUpgradeFinalizedStatusRunnable();
+    m_injector.injectMembers(runnable);
+
+    // run the alert
+    runnable.run();
+
+    assertEquals(1,
+      m_listener.getAlertEventReceivedCount(AlertReceivedEvent.class));
+
+    List<AlertEvent> events = m_listener.getAlertEventInstances(AlertReceivedEvent.class);
+    assertEquals(1, events.size());
+
+    AlertReceivedEvent event = (AlertReceivedEvent) events.get(0);
+    Alert alert = event.getAlert();
+    assertEquals("AMBARI", alert.getService());
+    assertEquals("AMBARI_SERVER", alert.getComponent());
+    assertEquals(AlertState.CRITICAL, alert.getState());
+    assertEquals(DEFINITION_NAME, alert.getName());
+
+    verify(m_cluster, m_clusters, m_definitionDao);
+  }
+
+  /**
+   *
+   */
+  private class MockModule implements Module {
+    /**
+     *
+     */
+    @Override
+    public void configure(Binder binder) {
+      Cluster cluster = EasyMock.createNiceMock(Cluster.class);
+
+      binder.bind(Clusters.class).toInstance(createNiceMock(Clusters.class));
+      binder.bind(OsFamily.class).toInstance(createNiceMock(OsFamily.class));
+      binder.bind(DBAccessor.class).toInstance(createNiceMock(DBAccessor.class));
+      binder.bind(Cluster.class).toInstance(cluster);
+      binder.bind(AlertDefinitionDAO.class).toInstance(createNiceMock(AlertDefinitionDAO.class));
+      binder.bind(AlertsDAO.class).toInstance(createNiceMock(AlertsDAO.class));
+      binder.bind(EntityManager.class).toInstance(createNiceMock(EntityManager.class));
+    }
+  }
+}


Mime
View raw message