|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.mule.transport.AbstractTransportMessageProcessTemplate<MessageReceiverType,ConnectorType>
public abstract class AbstractTransportMessageProcessTemplate<MessageReceiverType extends AbstractMessageReceiver,ConnectorType extends AbstractConnector>
Field Summary | |
---|---|
protected Log |
logger
|
Constructor Summary | |
---|---|
AbstractTransportMessageProcessTemplate(MessageReceiverType messageReceiver,
WorkManager flowExecutionWorkManager)
|
Method Summary | |
---|---|
abstract Object |
acquireMessage()
This method will only be called once for the MessageProcessContext |
void |
afterFailureProcessingFlow(MessagingException messagingException)
Call when the processing of the message through the flow fails. |
void |
afterFailureProcessingFlow(MuleException exception)
Call when the processing of the message through the flow fails in an exception strategy |
MuleEvent |
afterRouteEvent(MuleEvent muleEvent)
Post processing of the routed MuleEvent |
void |
afterSuccessfulProcessingFlow(MuleEvent response)
Call after successfully processing the message through the flow This method will always be called when the flow execution was successful. |
MuleEvent |
beforeRouteEvent(MuleEvent muleEvent)
Pre processing of the MuleEvent to route |
protected MuleEvent |
createEventFromMuleMessage(MuleMessage muleMessage)
|
protected MuleMessage |
createMessageFromSource(Object message)
|
void |
discardInvalidMessage()
Discards the message because the validation failed |
protected ConnectorType |
getConnector()
|
FlowConstruct |
getFlowConstruct()
|
WorkManager |
getFlowExecutionWorkManager()
|
protected InboundEndpoint |
getInboundEndpoint()
|
protected MessageReceiverType |
getMessageReceiver()
|
MessageSource |
getMessageSource()
|
protected MuleContext |
getMuleContext()
|
MuleEvent |
getMuleEvent()
|
Object |
getOriginalMessage()
|
protected OutputStream |
getOutputStream()
|
TransactionConfig |
getTransactionConfig()
|
protected void |
propagateRootMessageIdProperty(MuleMessage message)
|
MuleEvent |
routeEvent(MuleEvent muleEvent)
Routes the MuleEvent through the processors chain |
boolean |
supportsAsynchronousProcessing()
|
boolean |
validateMessage()
Validates the message content. |
protected void |
warnIfMuleClientSendUsed(MuleMessage message)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected transient Log logger
Constructor Detail |
---|
public AbstractTransportMessageProcessTemplate(MessageReceiverType messageReceiver, WorkManager flowExecutionWorkManager)
Method Detail |
---|
public MuleEvent getMuleEvent() throws MuleException
getMuleEvent
in interface FlowProcessingPhaseTemplate
MuleEvent
created from the original message
MuleException
public MessageSource getMessageSource()
getMessageSource
in interface MessageProcessContext
MessageSource
that retrieve the message. Can not be nullpublic Object getOriginalMessage() throws MuleException
getOriginalMessage
in interface FlowProcessingPhaseTemplate
MuleException
public void afterFailureProcessingFlow(MessagingException messagingException) throws MuleException
FlowProcessingPhaseTemplate
afterFailureProcessingFlow
in interface FlowProcessingPhaseTemplate
MuleException
public void afterFailureProcessingFlow(MuleException exception) throws MuleException
FlowProcessingPhaseTemplate
afterFailureProcessingFlow
in interface FlowProcessingPhaseTemplate
MuleException
public MuleEvent routeEvent(MuleEvent muleEvent) throws MuleException
FlowProcessingPhaseTemplate
MuleEvent
through the processors chain
routeEvent
in interface FlowProcessingPhaseTemplate
muleEvent
- MuleEvent
created from the raw message of this context
MuleEvent
MuleException
public void afterSuccessfulProcessingFlow(MuleEvent response) throws MuleException
FlowProcessingPhaseTemplate
afterSuccessfulProcessingFlow
in interface FlowProcessingPhaseTemplate
MuleException
public abstract Object acquireMessage() throws MuleException
MessageProcessContext
MessageSource
MuleException
protected void propagateRootMessageIdProperty(MuleMessage message)
public boolean validateMessage()
ValidationPhaseTemplate
ValidationPhaseTemplate.discardInvalidMessage()
will be executed so the implementation can save the reason why the message is invalid
to report why the message has been discarded when ValidationPhaseTemplate.discardInvalidMessage()
is called
validateMessage
in interface ValidationPhaseTemplate
public void discardInvalidMessage() throws MuleException
ValidationPhaseTemplate
discardInvalidMessage
in interface ValidationPhaseTemplate
MuleException
protected void warnIfMuleClientSendUsed(MuleMessage message)
protected MuleEvent createEventFromMuleMessage(MuleMessage muleMessage) throws MuleException
MuleException
protected OutputStream getOutputStream()
protected MuleMessage createMessageFromSource(Object message) throws MuleException
MuleException
protected MessageReceiverType getMessageReceiver()
protected InboundEndpoint getInboundEndpoint()
protected ConnectorType getConnector()
protected MuleContext getMuleContext()
public FlowConstruct getFlowConstruct()
getFlowConstruct
in interface MessageProcessContext
FlowConstruct
were the incoming message is going to be executed. Can not be nullpublic boolean supportsAsynchronousProcessing()
supportsAsynchronousProcessing
in interface MessageProcessContext
public MuleEvent beforeRouteEvent(MuleEvent muleEvent) throws MuleException
FlowProcessingPhaseTemplate
MuleEvent
to route
beforeRouteEvent
in interface FlowProcessingPhaseTemplate
MuleException
public MuleEvent afterRouteEvent(MuleEvent muleEvent) throws MuleException
FlowProcessingPhaseTemplate
MuleEvent
afterRouteEvent
in interface FlowProcessingPhaseTemplate
MuleException
public WorkManager getFlowExecutionWorkManager()
getFlowExecutionWorkManager
in interface MessageProcessContext
WorkManager
were the incoming message must be processed.
If null it will be executed in the same thread were the message was receivedpublic TransactionConfig getTransactionConfig()
getTransactionConfig
in interface MessageProcessContext
TransactionConfig
associated to the MessageSource
that received the message.
If null then no transaction config will be used.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |