Modifier and Type | Method and Description |
---|---|
protected FlowConstruct |
FlowConstructRunner.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
TestEventBuilder.build(FlowConstruct flow)
Produces an event with the specified configuration.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Flow
Defines a
Pipeline that represents a Mule flow. |
interface |
Pipeline
A pipeline has an ordered list of
Processor 's that are invoked in order to processor new messages received from it's
MessageSource |
Constructor and Description |
---|
FlowConstructInvalidException(I18nMessage message,
FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
static EventContext |
EventContextFactory.create(FlowConstruct flow,
ComponentLocation location)
Builds a new execution context with the given parameters.
|
static EventContext |
EventContextFactory.create(FlowConstruct flow,
ComponentLocation location,
String correlationId)
Builds a new execution context with the given parameters and an empty publisher.
|
static EventContext |
EventContextFactory.create(FlowConstruct flow,
ComponentLocation location,
String correlationId,
Optional<CompletableFuture<Void>> externalCompletion)
Builds a new execution context with the given parameters.
|
static EventContext |
EventContextFactory.create(FlowConstruct flow,
FlowExceptionHandler exceptionHandler,
ComponentLocation location,
String correlationId,
Optional<CompletableFuture<Void>> externalCompletion)
Builds a new execution context with the given parameters.
|
Modifier and Type | Method and Description |
---|---|
static ProcessingTime |
ProcessingTime.newInstance(FlowConstruct flow)
Create a ProcessingTime for the specified MuleSession.
|
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AbstractObjectFactory.flowConstruct |
Modifier and Type | Class and Description |
---|---|
class |
DefaultPolicyInstance |
Modifier and Type | Method and Description |
---|---|
Sink |
ProcessingStrategy.createSink(FlowConstruct flowConstruct,
ReactiveProcessor pipeline)
|
Copyright © 2018. All rights reserved.