Modifier and Type | Method and Description |
---|---|
protected CoreEvent |
FunctionalTestProcessor.doProcess(CoreEvent event)
The service method that implements the test component logic.
|
CoreEvent |
FunctionalTestProcessor.getLastReceivedMessage()
If enableMessageHistory = true, returns the last message received by the service in chronological order.
|
CoreEvent |
FunctionalTestProcessor.getReceivedMessage(int number)
If enableMessageHistory = true, returns a message received by the service in chronological order.
|
CoreEvent |
AssertionMessageProcessor.process(CoreEvent event) |
CoreEvent |
FunctionalTestProcessor.process(CoreEvent event) |
CoreEvent |
InvocationCountMessageProcessor.process(CoreEvent event) |
CoreEvent |
QueueReaderMessageProcessor.process(CoreEvent event) |
CoreEvent |
ResponseAssertionMessageProcessor.process(CoreEvent event) |
CoreEvent |
TestNonBlockingProcessor.process(CoreEvent event) |
CoreEvent |
ThrowProcessor.process(CoreEvent event) |
CoreEvent |
TestConnectorQueueHandler.read(String queueName)
Reads an event from a given queue waiting if necessary until an element becomes available.
|
CoreEvent |
TestConnectorQueueHandler.read(String queueName,
long timeout)
Reads an event from a given queue waiting up to the specified wait time if necessary for an element to become available.
|
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<CoreEvent> |
ResponseAssertionMessageProcessor.apply(org.reactivestreams.Publisher<CoreEvent> publisher) |
org.reactivestreams.Publisher<CoreEvent> |
TestNonBlockingProcessor.apply(org.reactivestreams.Publisher<CoreEvent> publisher) |
protected Function<CoreEvent,org.reactivestreams.Publisher<CoreEvent>> |
OnErrorCheckLogHandler.route(Exception exception) |
protected Function<CoreEvent,org.reactivestreams.Publisher<CoreEvent>> |
OnErrorCheckLogHandler.route(Exception exception) |
Modifier and Type | Method and Description |
---|---|
protected String |
FunctionalTestProcessor.append(String contents,
CoreEvent event)
Will append the value of
FunctionalTestProcessor.getAppendString() to the contents of the message. |
protected CoreEvent |
FunctionalTestProcessor.doProcess(CoreEvent event)
The service method that implements the test component logic.
|
void |
EventCallback.eventReceived(CoreEvent event,
Object component,
MuleContext muleContext) |
CoreEvent |
AssertionMessageProcessor.process(CoreEvent event) |
CoreEvent |
FunctionalTestProcessor.process(CoreEvent event) |
CoreEvent |
InvocationCountMessageProcessor.process(CoreEvent event) |
CoreEvent |
QueueReaderMessageProcessor.process(CoreEvent event) |
CoreEvent |
ResponseAssertionMessageProcessor.process(CoreEvent event) |
CoreEvent |
TestNonBlockingProcessor.process(CoreEvent event) |
CoreEvent |
ThrowProcessor.process(CoreEvent event) |
void |
TestConnectorQueueHandler.write(String queueName,
CoreEvent event)
Writes a event to a given queue waiting if necessary for space to become available
|
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<CoreEvent> |
ResponseAssertionMessageProcessor.apply(org.reactivestreams.Publisher<CoreEvent> publisher) |
org.reactivestreams.Publisher<CoreEvent> |
TestNonBlockingProcessor.apply(org.reactivestreams.Publisher<CoreEvent> publisher) |
Modifier and Type | Method and Description |
---|---|
static CoreEvent |
TestLegacyEventUtils.getCurrentEvent()
Return the event associated with the currently executing thread.
|
Modifier and Type | Method and Description |
---|---|
static FlowExceptionHandler |
TestLegacyEventUtils.getEffectiveExceptionHandler(CoreEvent event) |
static ProcessorsTrace |
TestLegacyEventUtils.getProcessorsTrace(CoreEvent event)
Events have a list of message processor paths it went trough so that the execution path of an event can be reconstructed
after it has executed.
|
static Object |
TestLegacyEventUtils.getSessionProperty(CoreEvent event,
String property) |
static DataType |
TestLegacyEventUtils.getSessionPropertyDataType(CoreEvent event,
String property) |
static Object |
TestLegacyEventUtils.removeSessionProperty(CoreEvent event,
String property) |
Modifier and Type | Method and Description |
---|---|
ExpectedError |
ExpectedError.expectEvent(org.hamcrest.Matcher<? extends CoreEvent> eventMatcher) |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
TestEventBuilder.build(FlowConstruct flow)
Produces an event with the specified configuration.
|
CoreEvent |
FlowConstructRunner.buildEvent()
Builds a new event based on this runner's config.
|
protected CoreEvent |
FlowConstructRunner.getOrBuildEvent() |
CoreEvent |
FlowRunner.run()
Runs the specified flow with the provided event and configuration, and performs a
FlowAssert#verify(String))
afterwards. |
CoreEvent |
FlowRunner.runAndVerify(String... flowNamesToVerify)
Runs the specified flow with the provided event and configuration, and performs a
FlowAssert#verify(String)) for each
flowNamesToVerify afterwards. |
CoreEvent |
FlowRunner.runNoVerify()
Runs the specified flow with the provided event and configuration.
|
Modifier and Type | Method and Description |
---|---|
void |
FlowRunner.runExpectingException(org.mule.tck.junit4.matcher.ErrorTypeMatcher matcher,
org.hamcrest.Matcher<CoreEvent> errorEventMatcher)
Runs the specified flow with the provided event and configuration expecting a failure with an
CoreEvent that matches
the given errorEventMatcher . |
void |
FlowRunner.runExpectingException(org.hamcrest.Matcher<Throwable> causeMatcher,
org.hamcrest.Matcher<CoreEvent> errorEventMatcher)
Runs the specified flow with the provided event and configuration expecting a failure with an
CoreEvent that matches
the given errorEventMatcher . |
Modifier and Type | Method and Description |
---|---|
void |
NotificationHelper.fireNotification(Component source,
CoreEvent event,
ComponentLocation location,
int action)
Fires a
ConnectorMessageNotification for the given arguments using the ServerNotificationHandler associated
to the given event and based on a ComponentLocation . |
Modifier and Type | Method and Description |
---|---|
void |
ExtendedExpressionManager.enrich(String expression,
CoreEvent event,
CoreEvent.Builder eventBuilder,
ComponentLocation componentLocation,
TypedValue value)
Deprecated.
Mutation via expressions is deprecated.
|
TypedValue |
ExpressionManager.evaluate(String expression,
CoreEvent event)
Execute the expression returning the result.
|
TypedValue |
ExpressionManager.evaluate(String expression,
CoreEvent event,
BindingContext context)
Execute the expression returning the result.
|
TypedValue |
ExpressionManager.evaluate(String expression,
CoreEvent event,
ComponentLocation componentLocation)
Execute the expression returning the result.
|
TypedValue |
ExpressionManager.evaluate(String expression,
CoreEvent event,
ComponentLocation componentLocation,
BindingContext context)
Execute the expression returning the result.
|
TypedValue |
ExtendedExpressionManager.evaluate(String expression,
CoreEvent event,
CoreEvent.Builder eventBuilder,
ComponentLocation componentLocation)
Deprecated.
Mutation via expressions is deprecated.
|
TypedValue |
ExpressionManager.evaluate(String expression,
DataType expectedOutputType,
BindingContext context,
CoreEvent event)
Evaluates an expression according to a given
BindingContext , the global one, the DataType of the expected
result and an CoreEvent . |
TypedValue |
ExpressionManager.evaluate(String expression,
DataType expectedOutputType,
BindingContext context,
CoreEvent event,
ComponentLocation componentLocation,
boolean failOnNull)
Evaluates an expression according to a given
BindingContext , the global one, the DataType of the expected
result and an CoreEvent . |
boolean |
ExpressionManager.evaluateBoolean(String expression,
CoreEvent event,
ComponentLocation componentLocation)
Evaluates an expression considering a
boolean as output. |
boolean |
ExpressionManager.evaluateBoolean(String expression,
CoreEvent event,
ComponentLocation componentLocation,
boolean nullReturnsTrue,
boolean nonBooleanReturnsTrue)
Evaluates an expression considering a
boolean as output. |
String |
ExtendedExpressionManager.parse(String expression,
CoreEvent event,
ComponentLocation componentLocation)
Deprecated.
Parsing of expressions is deprecated. Use standard evaluation instead.
|
String |
ExpressionManager.parseLogTemplate(String template,
CoreEvent event,
ComponentLocation componentLocation,
BindingContext bindingContext)
Parses a logging expression template by iterating through each expression and evaluating it.
|
Iterator<TypedValue<?>> |
ExpressionManager.split(String expression,
CoreEvent event,
BindingContext bindingContext)
Evaluates an expression according to a given
BindingContext , an CoreEvent . |
Iterator<TypedValue<?>> |
ExpressionManager.split(String expression,
CoreEvent event,
ComponentLocation componentLocation,
BindingContext bindingContext)
Evaluates an expression according to a given
BindingContext , an CoreEvent and a flowName. |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
CoreEvent.Builder.build()
Build a new
CoreEvent based on the state configured in the CoreEvent.Builder . |
Modifier and Type | Method and Description |
---|---|
static CoreEvent.Builder |
CoreEvent.builder(CoreEvent event)
Create new
CoreEvent.Builder based on an existing CoreEvent instance. |
static CoreEvent.Builder |
CoreEvent.builder(EventContext context,
CoreEvent event)
|
static <T> T |
CoreEvent.getVariableValueOrNull(String key,
CoreEvent event)
Helper method to get the value of a given variable in a null-safe manner such that
null is returned for non-existent
variables rather than a NoSuchElementException exception being thrown. |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
FlowExceptionHandler.handleException(Exception exception,
CoreEvent event)
Take some action when a messaging exception has occurred (i.e., there was a message in play when the exception occurred).
|
CoreEvent |
NullExceptionHandler.handleException(Exception exception,
CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
default org.reactivestreams.Publisher<CoreEvent> |
FlowExceptionHandler.apply(Exception exception) |
org.reactivestreams.Publisher<CoreEvent> |
NullExceptionHandler.apply(Exception exception) |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
FlowExceptionHandler.handleException(Exception exception,
CoreEvent event)
Take some action when a messaging exception has occurred (i.e., there was a message in play when the exception occurred).
|
CoreEvent |
NullExceptionHandler.handleException(Exception exception,
CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
Optional<ConfigurationInstance> |
ExtensionManager.getConfiguration(ExtensionModel extensionModel,
ComponentModel componentModel,
CoreEvent muleEvent)
|
ConfigurationInstance |
ExtensionManager.getConfiguration(String configurationProviderName,
CoreEvent event)
Returns a
ConfigurationInstance obtained through a previously registered ConfigurationProvider named as
configurationProvider |
Modifier and Type | Method and Description |
---|---|
void |
OutputHandler.write(CoreEvent event,
OutputStream out)
Write the event payload to the stream.
|
Modifier and Type | Method and Description |
---|---|
CoreEvent |
PolicyChain.process(CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<CoreEvent> |
PolicyChain.apply(org.reactivestreams.Publisher<CoreEvent> publisher) |
Optional<CoreEvent> |
PolicyStateHandler.getLatestState(PolicyStateId identifier) |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
PolicyChain.process(CoreEvent event) |
void |
PolicyStateHandler.updateState(PolicyStateId identifier,
CoreEvent lastStateEvent)
Updates the event of the policy for the context with the given identifier.
|
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<CoreEvent> |
PolicyChain.apply(org.reactivestreams.Publisher<CoreEvent> publisher) |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
Processor.process(CoreEvent event)
Invokes the MessageProcessor.
|
CoreEvent |
RaiseErrorProcessor.process(CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
default org.reactivestreams.Publisher<CoreEvent> |
Processor.apply(org.reactivestreams.Publisher<CoreEvent> publisher)
Applies a
CoreEvent > function transforming a stream of CoreEvent 's. |
Modifier and Type | Method and Description |
---|---|
void |
Sink.accept(CoreEvent event)
Submit the given
CoreEvent for processing without a timeout. |
boolean |
Sink.emit(CoreEvent event)
Submit the given
CoreEvent for processing. |
CoreEvent |
Processor.process(CoreEvent event)
Invokes the MessageProcessor.
|
CoreEvent |
RaiseErrorProcessor.process(CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
default org.reactivestreams.Publisher<CoreEvent> |
Processor.apply(org.reactivestreams.Publisher<CoreEvent> publisher)
Applies a
CoreEvent > function transforming a stream of CoreEvent 's. |
Modifier and Type | Method and Description |
---|---|
abstract SecurityContext |
AbstractAuthenticationFilter.authenticate(CoreEvent event) |
SecurityContext |
AuthenticationFilter.authenticate(CoreEvent event) |
SecurityContext |
AbstractAuthenticationFilter.doFilter(CoreEvent event) |
abstract SecurityContext |
AbstractSecurityFilter.doFilter(CoreEvent event) |
SecurityContext |
SecurityFilter.doFilter(CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
CursorProvider |
DefaultStreamingManager.manage(CursorProvider provider,
CoreEvent creatorEvent)
Becomes aware of the given
provider and returns a replacement provider
which is managed by the runtime, allowing for automatic resource handling |
CursorProvider |
StreamingManager.manage(CursorProvider provider,
CoreEvent creatorEvent)
Becomes aware of the given
provider and returns a replacement provider
which is managed by the runtime, allowing for automatic resource handling |
void |
DefaultStreamingManager.manage(InputStream stream,
CoreEvent creatorEvent)
Becomes aware of the given
inputStream and makes sure it is closed
by the time the given creatorEvent (and all its parent events) are completed. |
void |
StreamingManager.manage(InputStream inputStream,
CoreEvent creatorEvent)
Becomes aware of the given
inputStream and makes sure it is closed
by the time the given creatorEvent (and all its parent events) are completed. |
Object |
CursorProviderFactory.of(CoreEvent event,
T value)
Optionally creates a new
CursorProvider to buffer the given value . |
Modifier and Type | Method and Description |
---|---|
Object |
AbstractCursorStreamProviderFactory.of(CoreEvent event,
InputStream inputStream)
Optionally creates a new
CursorProvider to buffer the given value . |
protected abstract Object |
AbstractCursorStreamProviderFactory.resolve(InputStream inputStream,
CoreEvent event)
Implementations should use this method to actually create the output value
|
protected Object |
InMemoryCursorStreamProviderFactory.resolve(InputStream inputStream,
CoreEvent event)
Implementations should use this method to actually create the output value
|
Modifier and Type | Method and Description |
---|---|
CoreEvent |
AbstractTransformer.process(CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
protected Object |
AbstractMessageTransformer.checkReturnClass(Object object,
CoreEvent event)
Check if the return class is supported by this transformer
|
CoreEvent |
AbstractTransformer.process(CoreEvent event) |
Object |
AbstractMessageTransformer.transform(Object src,
Charset enc,
CoreEvent event) |
Object |
MessageTransformer.transform(Object src,
Charset encoding,
CoreEvent event)
Transforms the supplied data and returns the result
|
Object |
AbstractMessageTransformer.transform(Object src,
CoreEvent event) |
Object |
MessageTransformer.transform(Object src,
CoreEvent event)
Transforms the supplied data and returns the result
|
abstract Object |
AbstractMessageTransformer.transformMessage(CoreEvent event,
Charset outputEncoding)
Transform the message
|
Modifier and Type | Method and Description |
---|---|
static CoreEvent |
StreamingUtils.consumeRepeatablePayload(CoreEvent event)
If the
event has a repeatable payload (instance of CursorProvider ), then this method returns a new
event which payload has an equivalent, already consumed structure. |
static CoreEvent |
StreamingUtils.withCursoredEvent(CoreEvent event,
CheckedFunction<CoreEvent,CoreEvent> f)
Executes the given function
f considering that the given event might have a CursorProvider as
payload. |
Modifier and Type | Method and Description |
---|---|
static Function<CoreEvent,CoreEvent> |
StreamingUtils.updateEventForStreaming(StreamingManager streamingManager)
Provides a function that updates the payload value of an
CoreEvent by replacing it with a CursorProvider . |
static Function<CoreEvent,CoreEvent> |
StreamingUtils.updateEventForStreaming(StreamingManager streamingManager)
Provides a function that updates the payload value of an
CoreEvent by replacing it with a CursorProvider . |
Modifier and Type | Method and Description |
---|---|
static CoreEvent |
StreamingUtils.consumeRepeatablePayload(CoreEvent event)
If the
event has a repeatable payload (instance of CursorProvider ), then this method returns a new
event which payload has an equivalent, already consumed structure. |
static Object |
StreamingUtils.streamingContent(Object value,
CursorProviderFactory cursorProviderFactory,
CoreEvent event)
If the
cursorProviderFactory accepts the given value , then the result of invoking
CursorProviderFactory.of(CoreEvent, Object) is returned. |
static TypedValue |
StreamingUtils.updateTypedValueForStreaming(TypedValue value,
CoreEvent event,
StreamingManager streamingManager)
Updates the value a given
TypedValue instance by replacing it with a CursorProvider . |
static TypedValue |
StreamingUtils.updateTypedValueWithCursorProvider(TypedValue value,
CoreEvent event,
StreamingManager streamingManager)
|
static CoreEvent |
StreamingUtils.withCursoredEvent(CoreEvent event,
CheckedFunction<CoreEvent,CoreEvent> f)
Executes the given function
f considering that the given event might have a CursorProvider as
payload. |
Modifier and Type | Method and Description |
---|---|
static CoreEvent |
StreamingUtils.withCursoredEvent(CoreEvent event,
CheckedFunction<CoreEvent,CoreEvent> f)
Executes the given function
f considering that the given event might have a CursorProvider as
payload. |
static CoreEvent |
StreamingUtils.withCursoredEvent(CoreEvent event,
CheckedFunction<CoreEvent,CoreEvent> f)
Executes the given function
f considering that the given event might have a CursorProvider as
payload. |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
EventedExecutionContext.getEvent()
Returns the
CoreEvent on which an operation is to be executed |
CoreEvent |
EventedResult.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
EventedExecutionContext.changeEvent(CoreEvent updated)
Changes the
CoreEvent on which an operation is to be executed. |
static <T,A> EventedResult<T,A> |
EventedResult.from(CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
static CoreEvent |
MuleExtensionUtils.getInitialiserEvent()
Creates an empty event for extension initialization purposes
|
static CoreEvent |
MuleExtensionUtils.getInitialiserEvent(MuleContext muleContext)
Creates an empty event for extension initialization pusposes
|
Modifier and Type | Method and Description |
---|---|
CoreEvent |
LifecycleSensingMessageProcessor.process(CoreEvent event) |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
LifecycleSensingMessageProcessor.process(CoreEvent event) |
Copyright © 2018. All rights reserved.