public class MessageFactory extends Object
Modifier and Type | Field and Description |
---|---|
static String |
OOZIE_MESSAGE_FORMAT |
static String |
OOZIE_MESSAGE_SERIALIZE |
Constructor and Description |
---|
MessageFactory() |
Modifier and Type | Method and Description |
---|---|
static CoordinatorActionMessage |
createCoordinatorActionMessage(CoordinatorActionEvent coordActionEvent)
Constructs and returns the coordinator action message for coordinator
action event
|
static SLAMessage |
createSLAMessage(SLAEvent event)
Constructs and returns SLA notification message
|
static WorkflowJobMessage |
createWorkflowJobMessage(WorkflowJobEvent wfJobEvent)
Constructs and returns the workflow job message for workflow job event
|
static MessageSerializer |
getMessageSerializer()
Gets the configured serializer
|
public static final String OOZIE_MESSAGE_FORMAT
public static final String OOZIE_MESSAGE_SERIALIZE
public MessageFactory()
public static MessageSerializer getMessageSerializer()
public static WorkflowJobMessage createWorkflowJobMessage(WorkflowJobEvent wfJobEvent)
wfJobEvent
- the workflow job eventpublic static CoordinatorActionMessage createCoordinatorActionMessage(CoordinatorActionEvent coordActionEvent)
coordActionEvent
- the coordinator action eventpublic static SLAMessage createSLAMessage(SLAEvent event)
event
- SLA eventCopyright © 2015 Apache Software Foundation. All Rights Reserved.