public class SensingNullMessageProcessor extends AbstractNonBlockingMessageProcessor implements MessageProcessor
Modifier and Type | Field and Description |
---|---|
MuleEvent |
event |
Latch |
latch |
protected org.mule.tck.SensingNullMessageProcessor.InternalMessageSource |
source |
Thread |
thread |
PROPERTY_NAME
Constructor and Description |
---|
SensingNullMessageProcessor() |
SensingNullMessageProcessor(String appendString) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
MessageSource |
getMessageSource() |
boolean |
isNonBlocking(MuleEvent event) |
protected MuleEvent |
processBlocking(MuleEvent event) |
protected void |
processNonBlocking(MuleEvent event,
CompletionHandler completionHandler) |
void |
setWaitTime(long waitTime) |
process, setMessagingExceptionHandler
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
process
public MuleEvent event
public Latch latch
public Thread thread
protected org.mule.tck.SensingNullMessageProcessor.InternalMessageSource source
public SensingNullMessageProcessor()
public SensingNullMessageProcessor(String appendString)
protected void processNonBlocking(MuleEvent event, CompletionHandler completionHandler) throws MuleException
processNonBlocking
in class AbstractNonBlockingMessageProcessor
MuleException
protected MuleEvent processBlocking(MuleEvent event) throws MuleException
processBlocking
in class AbstractNonBlockingMessageProcessor
MuleException
public boolean isNonBlocking(MuleEvent event)
isNonBlocking
in class AbstractNonBlockingMessageProcessor
public void clear()
public MessageSource getMessageSource()
public void setWaitTime(long waitTime)
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.