001 /**
002 * Licensed to the Apache Software Foundation (ASF) under one
003 * or more contributor license agreements. See the NOTICE file
004 * distributed with this work for additional information
005 * regarding copyright ownership. The ASF licenses this file
006 * to you under the Apache License, Version 2.0 (the
007 * "License"); you may not use this file except in compliance
008 * with the License. You may obtain a copy of the License at
009 *
010 * http://www.apache.org/licenses/LICENSE-2.0
011 *
012 * Unless required by applicable law or agreed to in writing, software
013 * distributed under the License is distributed on an "AS IS" BASIS,
014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
015 * See the License for the specific language governing permissions and
016 * limitations under the License.
017 */
018 package org.apache.oozie.event.messaging;
019
020 import org.apache.hadoop.util.ReflectionUtils;
021 import org.apache.oozie.client.event.SLAEvent;
022 import org.apache.oozie.client.event.message.CoordinatorActionMessage;
023 import org.apache.oozie.client.event.message.WorkflowJobMessage;
024 import org.apache.oozie.client.event.message.SLAMessage;
025 import org.apache.oozie.event.CoordinatorActionEvent;
026 import org.apache.oozie.event.WorkflowJobEvent;
027 import org.apache.oozie.service.Services;
028
029 /**
030 * Factory for constructing messages and retrieving the serializer
031 */
032 public class MessageFactory {
033
034 public static final String OOZIE_MESSAGE_FORMAT = Services.get().getConf().get("message.format", "json");
035 public static final String OOZIE_MESSAGE_SERIALIZE = "oozie.jms.serialize.";
036
037 private static class MessageSerializerHolder {
038 private static String messageSerializerInstance = Services
039 .get()
040 .getConf()
041 .get(OOZIE_MESSAGE_SERIALIZE + OOZIE_MESSAGE_FORMAT,
042 "org.apache.oozie.event.messaging.JSONMessageSerializer");
043 public static final MessageSerializer INSTANCE;
044 static {
045 try {
046 INSTANCE = (MessageSerializer) ReflectionUtils.newInstance(Class.forName(messageSerializerInstance),
047 null);
048 }
049 catch (ClassNotFoundException cnfe) {
050 throw new IllegalStateException("Could not construct the serializer ", cnfe);
051 }
052 }
053 }
054
055 /**
056 * Gets the configured serializer
057 *
058 * @return
059 */
060 public static MessageSerializer getMessageSerializer() {
061 return MessageSerializerHolder.INSTANCE;
062 }
063
064 /**
065 * Constructs and returns the workflow job message for workflow job event
066 *
067 * @param wfJobEvent the workflow job event
068 * @return
069 */
070 public static WorkflowJobMessage createWorkflowJobMessage(WorkflowJobEvent wfJobEvent) {
071 WorkflowJobMessage wfJobMessage = new WorkflowJobMessage(wfJobEvent.getEventStatus(), wfJobEvent.getId(),
072 wfJobEvent.getParentId(), wfJobEvent.getStartTime(), wfJobEvent.getEndTime(), wfJobEvent.getStatus(),
073 wfJobEvent.getUser(), wfJobEvent.getAppName(), wfJobEvent.getErrorCode(), wfJobEvent.getErrorMessage());
074 return wfJobMessage;
075 }
076
077 /**
078 * Constructs and returns the coordinator action message for coordinator
079 * action event
080 *
081 * @param coordActionEvent the coordinator action event
082 * @return
083 */
084 public static CoordinatorActionMessage createCoordinatorActionMessage(CoordinatorActionEvent coordActionEvent) {
085 CoordinatorActionMessage coordActionMessage = new CoordinatorActionMessage(coordActionEvent.getEventStatus(),
086 coordActionEvent.getId(), coordActionEvent.getParentId(), coordActionEvent.getStartTime(),
087 coordActionEvent.getEndTime(), coordActionEvent.getNominalTime(), coordActionEvent.getStatus(),
088 coordActionEvent.getUser(), coordActionEvent.getAppName(), coordActionEvent.getMissingDeps(),
089 coordActionEvent.getErrorCode(), coordActionEvent.getErrorMessage());
090 return coordActionMessage;
091 }
092
093 /**
094 * Constructs and returns SLA notification message
095 * @param event SLA event
096 * @return
097 */
098 public static SLAMessage createSLAMessage(SLAEvent event) {
099 SLAMessage slaMessage = new SLAMessage(event.getEventStatus(), event.getSLAStatus(), event.getAppType(),
100 event.getAppName(), event.getUser(), event.getId(), event.getParentId(), event.getNominalTime(),
101 event.getExpectedStart(), event.getActualStart(), event.getExpectedEnd(), event.getActualEnd(),
102 event.getExpectedDuration(), event.getActualDuration(), event.getNotificationMsg(), event.getUpstreamApps());
103 return slaMessage;
104 }
105 }