org.mule.functional.api.component

Class ResponseAssertionMessageProcessor

java.lang.Object

org.mule.runtime.api.component.AbstractComponent

org.mule.functional.api.component.AssertionMessageProcessor

org.mule.functional.api.component.ResponseAssertionMessageProcessor

All Implemented Interfaces:

Function<org.reactivestreams.Publisher<CoreEvent>,org.reactivestreams.Publisher<CoreEvent>>, Component, Startable, InterceptingMessageProcessor, Processor, ReactiveProcessor, org.mule.tck.processor.FlowAssertion

public class ResponseAssertionMessageProcessor
extends AssertionMessageProcessor
implements InterceptingMessageProcessor, Startable

Nested Class Summary

Nested classes/interfaces inherited from interface org.mule.runtime.core.api.processor.ReactiveProcessor

ReactiveProcessor.ProcessingType

Field Summary

Fields

Modifier and Type	Field and Description
protected String	responseExpression

Fields inherited from class org.mule.functional.api.component.AssertionMessageProcessor

expression, expressionManager, message, needToMatchCount

Fields inherited from class org.mule.runtime.api.component.AbstractComponent

LOCATION_KEY, ROOT_CONTAINER_NAME_KEY

Fields inherited from interface org.mule.runtime.api.lifecycle.Startable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.component.Component

ANNOTATIONS_PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
ResponseAssertionMessageProcessor()

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<CoreEvent>	apply(org.reactivestreams.Publisher<CoreEvent> publisher) Applies a CoreEvent > function transforming a stream of CoreEvent's.
protected String	generateTaskToken()
CoreEvent	process(CoreEvent event) Invokes the MessageProcessor.
Boolean	responseCountFailOrNullEvent()
Boolean	responseExpressionFailed()
void	setListener(Processor listener) Set the MessageProcessor listener that will be invoked when a message is received or generated.
void	setResponseCount(int responseCount)
void	setResponseExpression(String responseExpression)
void	setResponseSameTask(boolean responseSameTask)
void	start()
void	verify() If result evaluated to false in some processed event or the last processed event was null, then assert fails, otherwise: count was set & count processes were done => ok count was set & count processes were not done => fail count was not set & at least one processing were done => ok

Methods inherited from class org.mule.functional.api.component.AssertionMessageProcessor

countFailOrNullEvent, expressionFailed, failureMessagePrefix, setCount, setExpression, setExpressionManager, setMessage

Methods inherited from class org.mule.runtime.api.component.AbstractComponent

getAnnotation, getAnnotations, getLocation, getRootContainerLocation, setAnnotations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.mule.runtime.core.api.processor.InterceptingMessageProcessor

isBlocking

Methods inherited from interface org.mule.runtime.core.api.processor.ReactiveProcessor

getProcessingType

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Field Detail

responseExpression

protected String responseExpression

Constructor Detail

ResponseAssertionMessageProcessor

public ResponseAssertionMessageProcessor()

Method Detail

start

public void start()
           throws InitialisationException

Specified by:

start in interface Startable

Overrides:

start in class AssertionMessageProcessor

Throws:

InitialisationException

process

public CoreEvent process(CoreEvent event)
                  throws MuleException

Description copied from interface: Processor

Invokes the MessageProcessor.

Specified by:

process in interface Processor

Overrides:

process in class AssertionMessageProcessor

Parameters:

event - MuleEvent to be processed

Returns:

optional response MuleEvent

Throws:

MuleException

apply

public org.reactivestreams.Publisher<CoreEvent> apply(org.reactivestreams.Publisher<CoreEvent> publisher)

Description copied from interface: Processor

Applies a CoreEvent > function transforming a stream of CoreEvent's.

The default implementation delegates to Processor.process(CoreEvent) and will:

1. propagate any exception thrown
2. drop events if invocation of Processor.process(CoreEvent) returns null.

Specified by:

apply in interface Function<org.reactivestreams.Publisher<CoreEvent>,org.reactivestreams.Publisher<CoreEvent>>

Specified by:

apply in interface Processor

Parameters:

publisher - the event stream to transform

Returns:

the transformed event stream

generateTaskToken

protected String generateTaskToken()

verify

public void verify()
            throws InterruptedException

Description copied from class: AssertionMessageProcessor

If result evaluated to false in some processed event or the last processed event was null, then assert fails, otherwise:

count was set & count processes were done => ok count was set & count processes were not done => fail count was not set & at least one processing were done => ok

Specified by:

verify in interface org.mule.tck.processor.FlowAssertion

Overrides:

verify in class AssertionMessageProcessor

Throws:

InterruptedException

responseCountFailOrNullEvent

public Boolean responseCountFailOrNullEvent()
                                     throws InterruptedException

Throws:

InterruptedException

responseExpressionFailed

public Boolean responseExpressionFailed()

setListener

public void setListener(Processor listener)

Description copied from interface: InterceptingMessageProcessor

Set the MessageProcessor listener that will be invoked when a message is received or generated.

Specified by:

setListener in interface InterceptingMessageProcessor

setResponseExpression

public void setResponseExpression(String responseExpression)

setResponseCount

public void setResponseCount(int responseCount)

setResponseSameTask

public void setResponseSameTask(boolean responseSameTask)