org.apache.oozie.event.messaging

Class MessageFactory

java.lang.Object

org.apache.oozie.event.messaging.MessageFactory

public class MessageFactory
extends Object

Factory for constructing messages and retrieving the serializer

Field Summary

Fields

Modifier and Type	Field and Description
static String	OOZIE_MESSAGE_FORMAT
static String	OOZIE_MESSAGE_SERIALIZE

Constructor Summary

Constructors

Constructor and Description
MessageFactory()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

OOZIE_MESSAGE_FORMAT

public static final String OOZIE_MESSAGE_FORMAT

OOZIE_MESSAGE_SERIALIZE

public static final String OOZIE_MESSAGE_SERIALIZE

See Also:

Constant Field Values

Constructor Detail

MessageFactory

public MessageFactory()

Method Detail

getMessageSerializer

public static MessageSerializer getMessageSerializer()

Gets the configured serializer

Returns:

createWorkflowJobMessage

public static WorkflowJobMessage createWorkflowJobMessage(WorkflowJobEvent wfJobEvent)

Constructs and returns the workflow job message for workflow job event

Parameters:

wfJobEvent - the workflow job event

Returns:

createCoordinatorActionMessage

public static CoordinatorActionMessage createCoordinatorActionMessage(CoordinatorActionEvent coordActionEvent)

Constructs and returns the coordinator action message for coordinator action event

Parameters:

coordActionEvent - the coordinator action event

Returns:

createSLAMessage

public static SLAMessage createSLAMessage(SLAEvent event)

Constructs and returns SLA notification message

Parameters:

event - SLA event

Returns: