org.apache.oozie.jms
Class JMSJobEventListener

java.lang.Object
  extended by org.apache.oozie.event.listener.JobEventListener
      extended by 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


Copyright © 2013 Apache Software Foundation. All Rights Reserved.