| /** |
| * 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.oozie.sla; |
| |
| import java.util.Date; |
| |
| import org.apache.hadoop.conf.Configuration; |
| import org.apache.oozie.AppType; |
| import org.apache.oozie.action.email.EmailActionExecutor; |
| import org.apache.oozie.client.event.JobEvent; |
| import org.apache.oozie.client.event.SLAEvent; |
| import org.apache.oozie.client.event.SLAEvent.EventStatus; |
| import org.apache.oozie.service.Services; |
| import org.apache.oozie.sla.SLACalcStatus; |
| import org.apache.oozie.sla.SLARegistrationBean; |
| import org.apache.oozie.test.XTestCase; |
| import org.apache.oozie.util.DateUtils; |
| import org.junit.After; |
| import org.junit.Before; |
| |
| import com.icegreen.greenmail.util.GreenMail; |
| import com.icegreen.greenmail.util.ServerSetup; |
| |
| import javax.mail.Message.RecipientType; |
| import javax.mail.internet.MimeMessage; |
| |
| import org.apache.oozie.sla.listener.SLAEmailEventListener; |
| import org.apache.oozie.sla.listener.SLAEmailEventListener.EmailField; |
| import org.apache.oozie.sla.service.SLAService; |
| |
| public class TestSLAEmailEventListener extends XTestCase { |
| |
| private Services services; |
| private static final int SMTP_TEST_PORT = 3025; |
| private GreenMail greenMail; |
| private SLAEmailEventListener slaEmailListener; |
| private Configuration conf = null; |
| |
| @Before |
| @Override |
| protected void setUp() throws Exception { |
| super.setUp(); |
| services = new Services(); |
| conf = services.getConf(); |
| conf.set(EmailActionExecutor.EMAIL_SMTP_HOST, "localhost"); |
| conf.set(EmailActionExecutor.EMAIL_SMTP_PORT, String.valueOf(SMTP_TEST_PORT)); |
| conf.set(EmailActionExecutor.EMAIL_SMTP_AUTH, "false"); |
| conf.set(EmailActionExecutor.EMAIL_SMTP_USER, ""); |
| conf.set(EmailActionExecutor.EMAIL_SMTP_PASS, ""); |
| conf.set(EmailActionExecutor.EMAIL_SMTP_FROM, "oozie@localhost"); |
| conf.set(SLAEmailEventListener.BLACKLIST_CACHE_TIMEOUT, "1"); |
| conf.set(SLAEmailEventListener.BLACKLIST_FAIL_COUNT, "2"); |
| conf.set(SLAService.CONF_ALERT_EVENTS, SLAEvent.EventStatus.START_MISS.name() + "," |
| + SLAEvent.EventStatus.END_MISS + "," + SLAEvent.EventStatus.DURATION_MISS); |
| |
| greenMail = new GreenMail(new ServerSetup(SMTP_TEST_PORT, null, "smtp")); |
| greenMail.start(); |
| services.init(); |
| slaEmailListener = new SLAEmailEventListener(); |
| slaEmailListener.init(conf); |
| } |
| |
| @After |
| @Override |
| protected void tearDown() throws Exception { |
| if (null != greenMail) { |
| greenMail.stop(); |
| } |
| services.destroy(); |
| super.tearDown(); |
| } |
| |
| public void testOnStartMiss() throws Exception { |
| String id = "0000000-000000000000001-oozie-wrkf-C@1"; |
| SLACalcStatus event = _createSLACalcStatus(id); |
| SLARegistrationBean eventBean = event.getSLARegistrationBean(); |
| Date startDate = DateUtils.parseDateUTC("2013-01-01T00:00Z"); |
| Date actualstartDate = DateUtils.parseDateUTC("2013-01-01T01:00Z"); |
| event.setEventStatus(EventStatus.START_MISS); |
| event.setJobStatus(JobEvent.EventStatus.STARTED.toString()); |
| event.setId(id); |
| eventBean.setParentId("0000000-000000000000001-oozie-wrkf-C"); |
| eventBean.setAppName("Test-SLA-Start-Miss"); |
| eventBean.setUser("dummyuser"); |
| eventBean.setNominalTime(startDate); |
| eventBean.setExpectedStart(startDate); |
| eventBean.setNotificationMsg("Notification of Missing Expected Start Time"); |
| eventBean.setAlertContact("alert-receiver@oozie.com"); |
| event.setActualStart(actualstartDate); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| |
| slaEmailListener.onStartMiss(event); |
| |
| MimeMessage[] msgs = greenMail.getReceivedMessages(); |
| MimeMessage msg = msgs[0]; |
| // check message header |
| assertEquals(msg.getFrom()[0].toString(), "oozie@localhost"); |
| assertEquals(msg.getRecipients(RecipientType.TO)[0].toString(), "alert-receiver@oozie.com"); |
| assertEquals(msg.getSubject(), "OOZIE - SLA " + EventStatus.START_MISS |
| + " (AppName=Test-SLA-Start-Miss, JobID=0000000-000000000000001-oozie-wrkf-C@1)"); |
| // check message body |
| String msgBody = msg.getContent().toString(); |
| String headerSep = SLAEmailEventListener.EMAIL_BODY_HEADER_SEPARATER; |
| String sep = SLAEmailEventListener.EMAIL_BODY_FIELD_SEPARATER; |
| String indent = SLAEmailEventListener.EMAIL_BODY_FIELD_INDENT; |
| assertTrue(msgBody.indexOf("Status" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EVENT_STATUS.toString() + sep |
| + EventStatus.START_MISS.toString()) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOB_STATUS.toString() + sep |
| + JobEvent.EventStatus.STARTED.toString()) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.NOTIFICATION_MESSAGE.toString() + sep |
| + "Notification of Missing Expected Start Time") > -1); |
| assertTrue(msgBody.indexOf("Job Details" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.APP_TYPE.toString() + sep + AppType.COORDINATOR_ACTION) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.APP_NAME.toString() + sep + "Test-SLA-Start-Miss") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.USER.toString() + sep + "dummyuser") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOBID.toString() + sep |
| + "0000000-000000000000001-oozie-wrkf-C@1") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.PARENT_JOBID.toString() + sep |
| + "0000000-000000000000001-oozie-wrkf-C") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOB_URL.toString() + sep |
| + conf.get(SLAEmailEventListener.OOZIE_BASE_URL) + "/?job=" + "0000000-000000000000001-oozie-wrkf-C@1") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.PARENT_JOB_URL.toString() + sep |
| + conf.get(SLAEmailEventListener.OOZIE_BASE_URL) + "/?job=" + "0000000-000000000000001-oozie-wrkf-C") > -1); |
| assertTrue(msgBody.indexOf("SLA Details" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.NOMINAL_TIME.toString() + sep + startDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EXPECTED_START_TIME.toString() + sep + startDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.ACTUAL_START_TIME.toString() + sep + actualstartDate) > -1); |
| } |
| |
| public void testOnEndMiss() throws Exception { |
| String id = "0000000-000000000000001-oozie-wrkf-C@1"; |
| SLACalcStatus event = _createSLACalcStatus(id); |
| SLARegistrationBean eventBean = event.getSLARegistrationBean(); |
| Date expectedStartDate = DateUtils.parseDateUTC("2013-01-01T00:00Z"); |
| Date actualStartDate = DateUtils.parseDateUTC("2013-01-01T01:00Z"); |
| Date expectedEndDate = DateUtils.parseDateUTC("2013-01-01T12:00Z"); |
| Date actualEndDate = DateUtils.parseDateUTC("2013-01-01T13:00Z"); |
| event.setId(id); |
| eventBean.setParentId("0000000-000000000000001-oozie-wrkf-C"); |
| event.setEventStatus(EventStatus.END_MISS); |
| event.setJobStatus(JobEvent.EventStatus.SUCCESS.toString()); |
| eventBean.setAppName("Test-SLA-End-Miss"); |
| eventBean.setUser("dummyuser"); |
| eventBean.setNominalTime(expectedStartDate); |
| eventBean.setExpectedStart(expectedStartDate); |
| eventBean.setExpectedEnd(expectedEndDate); |
| eventBean.setNotificationMsg("notification of end miss"); |
| eventBean.setAlertContact("alert-receiver-endmiss@oozie.com"); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| eventBean.setExpectedStart(expectedStartDate); |
| eventBean.setExpectedEnd(expectedEndDate); |
| event.setActualStart(actualStartDate); |
| event.setActualEnd(actualEndDate); |
| |
| slaEmailListener.onEndMiss(event); |
| |
| MimeMessage[] msgs = greenMail.getReceivedMessages(); |
| MimeMessage msg = msgs[0]; |
| // check message header |
| assertEquals(msg.getFrom()[0].toString(), "oozie@localhost"); |
| assertEquals(msg.getRecipients(RecipientType.TO)[0].toString(), "alert-receiver-endmiss@oozie.com"); |
| assertEquals(msg.getSubject(), "OOZIE - SLA " + EventStatus.END_MISS |
| + " (AppName=Test-SLA-End-Miss, JobID=0000000-000000000000001-oozie-wrkf-C@1)"); |
| // check message body |
| String msgBody = msg.getContent().toString(); |
| String headerSep = SLAEmailEventListener.EMAIL_BODY_HEADER_SEPARATER; |
| String sep = SLAEmailEventListener.EMAIL_BODY_FIELD_SEPARATER; |
| String indent = SLAEmailEventListener.EMAIL_BODY_FIELD_INDENT; |
| assertTrue(msgBody.indexOf("Status" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EVENT_STATUS.toString() + sep + EventStatus.END_MISS.toString()) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOB_STATUS.toString() + sep |
| + JobEvent.EventStatus.SUCCESS.toString()) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.NOTIFICATION_MESSAGE.toString() + sep |
| + "notification of end miss") > -1); |
| |
| assertTrue(msgBody.indexOf("Job Details" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.APP_TYPE.toString() + sep + AppType.COORDINATOR_ACTION) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.APP_NAME.toString() + sep + "Test-SLA-End-Miss") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.USER.toString() + sep + "dummyuser") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOBID.toString() + sep |
| + "0000000-000000000000001-oozie-wrkf-C@1") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.PARENT_JOBID.toString() + sep |
| + "0000000-000000000000001-oozie-wrkf-C") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOB_URL.toString() + sep |
| + conf.get(SLAEmailEventListener.OOZIE_BASE_URL) + "/?job=" + "0000000-000000000000001-oozie-wrkf-C@1") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.PARENT_JOB_URL.toString() + sep |
| + conf.get(SLAEmailEventListener.OOZIE_BASE_URL) + "/?job=" + "0000000-000000000000001-oozie-wrkf-C") > -1); |
| |
| assertTrue(msgBody.indexOf("SLA Details" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.NOMINAL_TIME.toString() + sep + expectedStartDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EXPECTED_START_TIME.toString() + sep + expectedStartDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.ACTUAL_START_TIME.toString() + sep + actualStartDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EXPECTED_END_TIME.toString() + sep + expectedEndDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.ACTUAL_END_TIME.toString() + sep + actualEndDate) > -1); |
| |
| } |
| |
| public void testOnDurationMiss() throws Exception { |
| String id = "0000000-000000000000001-oozie-wrkf-C@1"; |
| SLACalcStatus event = _createSLACalcStatus(id); |
| SLARegistrationBean eventBean = event.getSLARegistrationBean(); |
| Date expectedStartDate = DateUtils.parseDateUTC("2013-01-01T00:00Z"); |
| Date actualStartDate = DateUtils.parseDateUTC("2013-01-01T00:10Z"); |
| Date expectedEndDate = DateUtils.parseDateUTC("2013-01-01T00:20Z"); |
| Date actualEndDate = DateUtils.parseDateUTC("2013-01-01T00:40Z"); |
| long expectedDuration = expectedEndDate.getTime() - expectedStartDate.getTime(); |
| long actualDuration = actualEndDate.getTime() - actualStartDate.getTime(); |
| long expectedDurationInMins = expectedDuration / 60000; |
| long actualDurationInMins = actualDuration / 60000; |
| event.setId(id); |
| eventBean.setParentId("0000000-000000000000001-oozie-wrkf-C"); |
| event.setEventStatus(EventStatus.DURATION_MISS); |
| event.setJobStatus(JobEvent.EventStatus.SUCCESS.toString()); |
| eventBean.setAppName("Test-SLA-Duration-Miss"); |
| eventBean.setUser("dummyuser"); |
| eventBean.setNominalTime(expectedStartDate); |
| eventBean.setExpectedStart(expectedStartDate); |
| eventBean.setExpectedEnd(expectedEndDate); |
| eventBean.setNotificationMsg("notification of duration miss"); |
| eventBean.setAlertContact("alert-receiver-durationmiss@oozie.com"); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| eventBean.setExpectedStart(expectedStartDate); |
| eventBean.setExpectedEnd(expectedEndDate); |
| event.setActualStart(actualStartDate); |
| event.setActualEnd(actualEndDate); |
| eventBean.setExpectedDuration(expectedDuration); |
| event.setActualDuration(actualDuration); |
| |
| slaEmailListener.onEndMiss(event); |
| |
| MimeMessage[] msgs = greenMail.getReceivedMessages(); |
| MimeMessage msg = msgs[0]; |
| // check message header |
| assertEquals(msg.getFrom()[0].toString(), "oozie@localhost"); |
| assertEquals(msg.getRecipients(RecipientType.TO)[0].toString(), "alert-receiver-durationmiss@oozie.com"); |
| assertEquals(msg.getSubject(), "OOZIE - SLA " + EventStatus.DURATION_MISS |
| + " (AppName=Test-SLA-Duration-Miss, JobID=0000000-000000000000001-oozie-wrkf-C@1)"); |
| // check message body |
| String msgBody = msg.getContent().toString(); |
| String headerSep = SLAEmailEventListener.EMAIL_BODY_HEADER_SEPARATER; |
| String sep = SLAEmailEventListener.EMAIL_BODY_FIELD_SEPARATER; |
| String indent = SLAEmailEventListener.EMAIL_BODY_FIELD_INDENT; |
| assertTrue(msgBody.indexOf("Status" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EVENT_STATUS.toString() + sep |
| + EventStatus.DURATION_MISS.toString()) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOB_STATUS.toString() + sep |
| + JobEvent.EventStatus.SUCCESS.toString()) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.NOTIFICATION_MESSAGE.toString() + sep |
| + "notification of duration miss") > -1); |
| |
| assertTrue(msgBody.indexOf("Job Details" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.APP_TYPE.toString() + sep + AppType.COORDINATOR_ACTION) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.APP_NAME.toString() + sep + "Test-SLA-Duration-Miss") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.USER.toString() + sep + "dummyuser") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOBID.toString() + sep |
| + "0000000-000000000000001-oozie-wrkf-C@1") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.PARENT_JOBID.toString() + sep |
| + "0000000-000000000000001-oozie-wrkf-C") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.JOB_URL.toString() + sep |
| + conf.get(SLAEmailEventListener.OOZIE_BASE_URL) + "/?job=" + "0000000-000000000000001-oozie-wrkf-C@1") > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.PARENT_JOB_URL.toString() + sep |
| + conf.get(SLAEmailEventListener.OOZIE_BASE_URL) + "/?job=" + "0000000-000000000000001-oozie-wrkf-C") > -1); |
| |
| assertTrue(msgBody.indexOf("SLA Details" + headerSep) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.NOMINAL_TIME.toString() + sep + expectedStartDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EXPECTED_START_TIME.toString() + sep + expectedStartDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.ACTUAL_START_TIME.toString() + sep + actualStartDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EXPECTED_END_TIME.toString() + sep + expectedEndDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.ACTUAL_END_TIME.toString() + sep + actualEndDate) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.EXPECTED_DURATION.toString() + sep + expectedDurationInMins) > -1); |
| assertTrue(msgBody.indexOf(indent + EmailField.ACTUAL_DURATION.toString() + sep + actualDurationInMins) > -1); |
| } |
| |
| public void testUserAlertEventSetting() throws Exception { |
| String id = "0000000-000000000000001-oozie-wrkf-C@1"; |
| SLACalcStatus event = _createSLACalcStatus(id); |
| SLARegistrationBean eventBean = event.getSLARegistrationBean(); |
| // user choose only END MISS, thus, START_MISS email should not be sent |
| eventBean.setAlertEvents(EventStatus.END_MISS.name()); |
| |
| Date startDate = DateUtils.parseDateUTC("2013-01-01T00:00Z"); |
| Date actualstartDate = DateUtils.parseDateUTC("2013-01-01T01:00Z"); |
| event.setEventStatus(EventStatus.START_MISS); |
| event.setId(id); |
| eventBean.setAppName("Test-SLA-Start-Miss"); |
| eventBean.setUser("dummyuser"); |
| eventBean.setNominalTime(startDate); |
| eventBean.setExpectedStart(startDate); |
| eventBean.setAlertContact("alert-receiver@oozie.com"); |
| event.setActualStart(actualstartDate); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| |
| slaEmailListener.onStartMiss(event); |
| |
| // START_MISS should not be sent |
| MimeMessage[] msgs = greenMail.getReceivedMessages(); |
| assertEquals(msgs.length, 0); |
| |
| // DURATION_MISS should not be sent |
| event.setEventStatus(EventStatus.DURATION_MISS); |
| slaEmailListener.onDurationMiss(event); |
| msgs = greenMail.getReceivedMessages(); |
| assertEquals(msgs.length, 0); |
| |
| // END_MISS should be sent |
| event.setEventStatus(EventStatus.END_MISS); |
| slaEmailListener.onEndMiss(event); |
| msgs = greenMail.getReceivedMessages(); |
| assertNotNull(msgs[0]); |
| } |
| |
| public void testInvalidDestAddress() throws Exception { |
| String id = "0000000-000000000000001-oozie-wrkf-C@1"; |
| SLACalcStatus event = _createSLACalcStatus(id); |
| SLARegistrationBean eventBean = event.getSLARegistrationBean(); |
| Date startDate = DateUtils.parseDateUTC("2013-01-01T00:00Z"); |
| // set invalid address as alert contact |
| eventBean.setAlertContact("invalidAddress"); |
| event.setEventStatus(EventStatus.START_MISS); |
| event.setId(id); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| eventBean.setAppName("Test-SLA-Start-Miss"); |
| eventBean.setUser("dummyuser"); |
| eventBean.setExpectedStart(startDate); |
| eventBean.setNotificationMsg("notification of start miss"); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| event.setActualStart(DateUtils.parseDateUTC("2013-01-01T01:00Z")); |
| |
| slaEmailListener.onStartMiss(event); |
| |
| MimeMessage[] msgs = greenMail.getReceivedMessages(); |
| assertEquals(msgs.length, 0); |
| } |
| |
| public void testNoDestAddress() throws Exception { |
| String id = "0000000-000000000000001-oozie-wrkf-C@1"; |
| SLACalcStatus event = _createSLACalcStatus(id); |
| SLARegistrationBean eventBean = event.getSLARegistrationBean(); |
| Date startDate = DateUtils.parseDateUTC("2013-01-01T00:00Z"); |
| // set empty address as alert contact |
| eventBean.setAlertContact(""); |
| event.setEventStatus(EventStatus.START_MISS); |
| event.setId(id); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| eventBean.setAppName("Test-SLA-Start-Miss"); |
| eventBean.setUser("dummyuser"); |
| eventBean.setExpectedStart(startDate); |
| eventBean.setNotificationMsg("notification of start miss"); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| event.setActualStart(DateUtils.parseDateUTC("2013-01-01T01:00Z")); |
| |
| slaEmailListener.onStartMiss(event); |
| |
| MimeMessage[] msgs = greenMail.getReceivedMessages(); |
| assertEquals(msgs.length, 0); |
| } |
| |
| public void testMultipleDestAddress() throws Exception { |
| String id = "0000000-000000000000001-oozie-wrkf-C@1"; |
| SLACalcStatus event = _createSLACalcStatus(id); |
| SLARegistrationBean eventBean = event.getSLARegistrationBean(); |
| Date startDate = DateUtils.parseDateUTC("2013-01-01T00:00Z"); |
| // set multiple addresses as alert contact |
| eventBean.setAlertContact("alert-receiver1@oozie.com, alert-receiver2@oozie.com"); |
| event.setEventStatus(EventStatus.START_MISS); |
| event.setId(id); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| eventBean.setAppName("Test-SLA-Start-Miss"); |
| eventBean.setUser("dummyuser"); |
| eventBean.setExpectedStart(startDate); |
| eventBean.setNotificationMsg("notification of start miss"); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| event.setActualStart(DateUtils.parseDateUTC("2013-01-01T01:00Z")); |
| |
| slaEmailListener.onStartMiss(event); |
| |
| MimeMessage[] msgs = greenMail.getReceivedMessages(); |
| MimeMessage msg = msgs[0]; |
| assertEquals(msg.getFrom()[0].toString(), "oozie@localhost"); |
| assertEquals(msg.getRecipients(RecipientType.TO)[0].toString(), "alert-receiver1@oozie.com"); |
| assertEquals(msg.getRecipients(RecipientType.TO)[1].toString(), "alert-receiver2@oozie.com"); |
| } |
| |
| public void testBlackList() throws Exception { |
| String blackListedEmail = "alert-receiver@oozie.com"; |
| // add email to blacklist |
| slaEmailListener.addBlackList(blackListedEmail); |
| String id = "0000000-000000000000001-oozie-wrkf-C@1"; |
| SLACalcStatus event = _createSLACalcStatus(id); |
| SLARegistrationBean eventBean = event.getSLARegistrationBean(); |
| event.setEventStatus(EventStatus.START_MISS); |
| eventBean.setAlertContact(blackListedEmail); |
| eventBean.setAppType(AppType.COORDINATOR_ACTION); |
| eventBean.setAppName("Test-SLA-Start-Miss"); |
| eventBean.setUser("dummyuser"); |
| eventBean.setAlertContact("alert-receiver@oozie.com"); |
| event.setActualStart(DateUtils.parseDateUTC("2013-01-01T01:00Z")); |
| |
| // blacklist blocks email from being sent out |
| slaEmailListener.onStartMiss(event); |
| MimeMessage[] msgs = greenMail.getReceivedMessages(); |
| assertEquals(msgs.length, 0); |
| |
| // wait 1.5 sec (cache timeout set to 1sec in test's setup) |
| Thread.sleep(1500); |
| |
| // cache is evicted |
| slaEmailListener.onStartMiss(event); |
| msgs = greenMail.getReceivedMessages(); |
| assertEquals(msgs.length, 1); |
| } |
| |
| private SLACalcStatus _createSLACalcStatus(String actionId) { |
| SLARegistrationBean reg = new SLARegistrationBean(); |
| reg.setId(actionId); |
| reg.setAppType(AppType.COORDINATOR_ACTION); |
| return new SLACalcStatus(reg); |
| } |
| } |
