diff options
author | an4828 <nekrassov@att.com> | 2017-09-15 15:28:53 -0400 |
---|---|---|
committer | an4828 <nekrassov@att.com> | 2017-09-18 09:24:04 -0400 |
commit | 4edf0fa48892bf38d0e3838d125e9bf2324b38e0 (patch) | |
tree | 7216dae042828ec2cf38cb9300af1a32a17b3b91 /dcae-analytics-cdap-tca/src/test/java/org/openecomp/dcae/apod/analytics/cdap/tca/worker/TCADMaaPPublisherWorkerTest.java | |
parent | 82aaf956855507e5a72d5ef5b45e398430d04a7a (diff) |
Add support for ABATED alerts within CDAP TCA
Change-Id: Iae560a2d0a47b30b41cd31206dc481a08e4930f7
Signed-off-by: an4828 <nekrassov@att.com>
Issue-ID: DCAEGEN2-107
Signed-off-by: an4828 <nekrassov@att.com>
Diffstat (limited to 'dcae-analytics-cdap-tca/src/test/java/org/openecomp/dcae/apod/analytics/cdap/tca/worker/TCADMaaPPublisherWorkerTest.java')
-rw-r--r-- | dcae-analytics-cdap-tca/src/test/java/org/openecomp/dcae/apod/analytics/cdap/tca/worker/TCADMaaPPublisherWorkerTest.java | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/dcae-analytics-cdap-tca/src/test/java/org/openecomp/dcae/apod/analytics/cdap/tca/worker/TCADMaaPPublisherWorkerTest.java b/dcae-analytics-cdap-tca/src/test/java/org/openecomp/dcae/apod/analytics/cdap/tca/worker/TCADMaaPPublisherWorkerTest.java index f2eeef8..2324b38 100644 --- a/dcae-analytics-cdap-tca/src/test/java/org/openecomp/dcae/apod/analytics/cdap/tca/worker/TCADMaaPPublisherWorkerTest.java +++ b/dcae-analytics-cdap-tca/src/test/java/org/openecomp/dcae/apod/analytics/cdap/tca/worker/TCADMaaPPublisherWorkerTest.java @@ -20,10 +20,12 @@ package org.openecomp.dcae.apod.analytics.cdap.tca.worker; +import co.cask.cdap.api.app.ApplicationSpecification; import co.cask.cdap.api.worker.WorkerConfigurer; import co.cask.cdap.api.worker.WorkerContext; import org.junit.Before; import org.junit.Test; +import org.mockito.Mockito; import org.openecomp.dcae.apod.analytics.cdap.common.CDAPComponentsConstants; import org.openecomp.dcae.apod.analytics.cdap.common.exception.CDAPSettingsException; import org.openecomp.dcae.apod.analytics.cdap.tca.BaseAnalyticsCDAPTCAUnitTest; @@ -46,6 +48,7 @@ public class TCADMaaPPublisherWorkerTest extends BaseAnalyticsCDAPTCAUnitTest { private WorkerConfigurer workerConfigurer; private WorkerContext workerContext; private TCADMaaPPublisherWorker publisherWorker; + private ApplicationSpecification mockApplicationSpecification; @Before public void before() throws Exception { @@ -53,6 +56,8 @@ public class TCADMaaPPublisherWorkerTest extends BaseAnalyticsCDAPTCAUnitTest { workerContext = mock(WorkerContext.class); doNothing().when(workerConfigurer).setName(anyString()); doNothing().when(workerConfigurer).setDescription(anyString()); + mockApplicationSpecification = Mockito.mock(ApplicationSpecification.class); + when(workerContext.getApplicationSpecification()).thenReturn(mockApplicationSpecification); publisherWorker = new TCADMaaPPublisherWorker(VES_ALERTS_TABLE_NAME); } @@ -68,12 +73,14 @@ public class TCADMaaPPublisherWorkerTest extends BaseAnalyticsCDAPTCAUnitTest { @Test(expected = CDAPSettingsException.class) public void testInitializeWhenSettingsHaveErrors() throws Exception { + when(mockApplicationSpecification.getConfiguration()).thenReturn("{}"); publisherWorker.initialize(workerContext); } @Test public void testInitializeWhenSettingsAreValid() throws Exception { when(workerContext.getRuntimeArguments()).thenReturn(getPreferenceMap()); + when(mockApplicationSpecification.getConfiguration()).thenReturn(fromStream(TCA_APP_CONFIG_FILE_LOCATION)); publisherWorker.initialize(workerContext); } |