|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.oozie.event.listener.JobEventListener org.apache.oozie.jms.JMSJobEventListener
public class JMSJobEventListener
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 |
---|
public static final String JMS_CONNECTION_PROPERTIES
public static final String JMS_SESSION_OPTS
public static final String JMS_DELIVERY_MODE
public static final String JMS_EXPIRATION_DATE
Constructor Detail |
---|
public JMSJobEventListener()
Method Detail |
---|
public void init(org.apache.hadoop.conf.Configuration conf)
JobEventListener
init
in class JobEventListener
protected void sendMessage(Map<String,String> messageProperties, String messageBody, String topicName, String messageFormat)
public void onWorkflowJobEvent(WorkflowJobEvent event)
JobEventListener
onWorkflowJobEvent
in class JobEventListener
public void onCoordinatorActionEvent(CoordinatorActionEvent event)
JobEventListener
onCoordinatorActionEvent
in class JobEventListener
protected String getTopic(WorkflowJobEvent event)
protected String getTopic(CoordinatorActionEvent event)
public void onWorkflowActionEvent(WorkflowActionEvent wae)
JobEventListener
onWorkflowActionEvent
in class JobEventListener
public void onCoordinatorJobEvent(CoordinatorJobEvent wje)
JobEventListener
onCoordinatorJobEvent
in class JobEventListener
public void onBundleJobEvent(BundleJobEvent wje)
JobEventListener
onBundleJobEvent
in class JobEventListener
public void destroy()
JobEventListener
destroy
in class JobEventListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |