public class JMSJobEventListener extends JobEventListener
Modifier and Type | Field and Description |
---|---|
static String |
JMS_CONNECTION_PROPERTIES |
static String |
JMS_DELIVERY_MODE |
static String |
JMS_EXPIRATION_DATE |
static String |
JMS_SESSION_OPTS |
Constructor and Description |
---|
JMSJobEventListener() |
Modifier and Type | Method and Description |
---|---|
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) |
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
public JMSJobEventListener()
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
Copyright © 2016 Apache Software Foundation. All rights reserved.