public class MessageProcessingFlowTraceManager extends LocationExecutionContextProvider implements FlowTraceManager, MuleContextAware, Initialisable, Disposable
Modifier and Type | Field and Description |
---|---|
static String |
FLOW_STACK_INFO_KEY |
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
MessageProcessingFlowTraceManager() |
Modifier and Type | Method and Description |
---|---|
void |
dispose()
A lifecycle method where implementor should free up any resources.
|
Map<String,Object> |
getContextInfo(MuleEvent muleEvent,
MessageProcessor lastProcessed) |
protected void |
handleNotificationListeners() |
void |
initialise()
Method used to perform any initialisation work.
|
void |
onFlowComplete(MuleEvent muleEvent)
Handles the completion of the current flow for the given event.
|
void |
onFlowStart(MuleEvent muleEvent,
String flowName)
Handles the start of the passed flowName for the given event.
|
void |
onMessageProcessorNotificationPreInvoke(MessageProcessorNotification notification)
Callback method for when a message processor is about to be invoked.
|
void |
onPipelineNotificationComplete(PipelineMessageNotification notification)
Callback method for when a flow or sub-flow called from a
flow-ref component has been completed. |
void |
onPipelineNotificationStart(PipelineMessageNotification notification)
Callback method for when a flow or sub-flow is about to be called from a
flow-ref . |
protected void |
removeNotificationListeners() |
void |
setMuleContext(MuleContext context) |
addMetadataAnnotationsFromXml, getDocName, getSourceFile, getSourceFileLine, getSourceXML, resolveProcessorRepresentation
public static final String FLOW_STACK_INFO_KEY
public void setMuleContext(MuleContext context)
setMuleContext
in interface MuleContextAware
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered frompublic void dispose()
Disposable
dispose
in interface Disposable
protected void handleNotificationListeners()
protected void removeNotificationListeners()
public void onMessageProcessorNotificationPreInvoke(MessageProcessorNotification notification)
ProcessorsTrace
and FlowCallStack
accordingly.notification
- the notification that contains the event and the processor that is about to be invoked.DefaultProcessorsTrace.addExecutedProcessors(String)
,
DefaultFlowCallStack.setCurrentProcessorPath(String)
public void onPipelineNotificationComplete(PipelineMessageNotification notification)
flow-ref
component has been completed.notification
- the notification that contains the event and the processor that is about to be invoked.public void onPipelineNotificationStart(PipelineMessageNotification notification)
flow-ref
.notification
- the notification that contains the event and the processor that is about to be invoked.public void onFlowStart(MuleEvent muleEvent, String flowName)
FlowTraceManager
onFlowStart
in interface FlowTraceManager
muleEvent
- the event for which the flow is being startedflowName
- the name of the flow that is about to startpublic void onFlowComplete(MuleEvent muleEvent)
FlowTraceManager
onFlowComplete
in interface FlowTraceManager
muleEvent
- the event for which the flow is being completedpublic Map<String,Object> getContextInfo(MuleEvent muleEvent, MessageProcessor lastProcessed)
getContextInfo
in interface ExceptionContextProvider
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.