This project has retired. For details please refer to its Attic page.

org.apache.oozie.jms
Class JMSJobEventListener

java.lang.Object
  org.apache.oozie.event.listener.JobEventListener
      org.apache.oozie.jms.JMSJobEventListener

public class JMSJobEventListener
extends JobEventListener

Class to send JMS notifications related to job events.

Field Summary

static String	JMS_CONNECTION_PROPERTIES
static String	JMS_DELIVERY_MODE
static String	JMS_EXPIRATION_DATE
static String	JMS_SESSION_OPTS

Constructor Summary

JMSJobEventListener()

Method Summary

void	destroy() Destroy the listener
protected String	getTopic(CoordinatorActionEvent event)
protected String	getTopic(WorkflowJobEvent event)
void	init(org.apache.hadoop.conf.Configuration conf) Initialize the listener
void	onBundleJobEvent(BundleJobEvent wje) On bundle job transition
void	onCoordinatorActionEvent(CoordinatorActionEvent event) On coordinator action transition
void	onCoordinatorJobEvent(CoordinatorJobEvent wje) On coordinator job transition
void	onWorkflowActionEvent(WorkflowActionEvent wae) On workflow action transition
void	onWorkflowJobEvent(WorkflowJobEvent event) On workflow job transition
protected void	sendMessage(Map<String,String> messageProperties, String messageBody, String topicName, String messageFormat)

Methods inherited from class java.lang.Object

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

Field Detail

JMS_CONNECTION_PROPERTIES

public static final String JMS_CONNECTION_PROPERTIES

See Also:

Constant Field Values

JMS_SESSION_OPTS

public static final String JMS_SESSION_OPTS

See Also:

Constant Field Values

JMS_DELIVERY_MODE

public static final String JMS_DELIVERY_MODE

See Also:

Constant Field Values

JMS_EXPIRATION_DATE

public static final String JMS_EXPIRATION_DATE

See Also:

Constant Field Values

Constructor Detail

JMSJobEventListener

public JMSJobEventListener()

Method Detail

init

public void init(org.apache.hadoop.conf.Configuration conf)

Description copied from class: JobEventListener

Initialize the listener

Specified by:

init in class JobEventListener

sendMessage

protected void sendMessage(Map<String,String> messageProperties,
                           String messageBody,
                           String topicName,
                           String messageFormat)

onWorkflowJobEvent

public void onWorkflowJobEvent(WorkflowJobEvent event)

Description copied from class: JobEventListener

On workflow job transition

Specified by:

onWorkflowJobEvent in class JobEventListener

onCoordinatorActionEvent

public void onCoordinatorActionEvent(CoordinatorActionEvent event)

Description copied from class: JobEventListener

On coordinator action transition

Specified by:

onCoordinatorActionEvent in class JobEventListener

getTopic

protected String getTopic(WorkflowJobEvent event)

getTopic

protected String getTopic(CoordinatorActionEvent event)

onWorkflowActionEvent

public void onWorkflowActionEvent(WorkflowActionEvent wae)

Description copied from class: JobEventListener

On workflow action transition

Specified by:

onWorkflowActionEvent in class JobEventListener

onCoordinatorJobEvent

public void onCoordinatorJobEvent(CoordinatorJobEvent wje)

Description copied from class: JobEventListener

On coordinator job transition

Specified by:

onCoordinatorJobEvent in class JobEventListener

onBundleJobEvent

public void onBundleJobEvent(BundleJobEvent wje)

Description copied from class: JobEventListener

On bundle job transition

Specified by:

onBundleJobEvent in class JobEventListener

destroy

public void destroy()

Description copied from class: JobEventListener

Destroy the listener

Specified by:

destroy in class JobEventListener