Element Summary

ElementDescriptionClass
async-bridgeorg.apache.servicemix.eip.patterns.AsyncBridge
componentAn EIP componentorg.apache.servicemix.eip.EIPComponent
content-based-routerA Content-Based Routerorg.apache.servicemix.eip.patterns.ContentBasedRouter
content-enricherA Content Enricherorg.apache.servicemix.eip.patterns.ContentEnricher
default-comparatorCompares {@link MessageExchange} sequence elements based on sequence numbers defined by their in-{@link NormalizedMessage}s. This comparator works on sequence numbers of type {@link Long}. Sequence numbers must be stored as {@link NormalizedMessage} properties. The property name under which the sequence number is stored is configured via this comparator's sequenceNumberKey property.org.apache.servicemix.eip.support.resequence.DefaultComparator
exchange-targetAn ExchangeTarget may be used to specify the target of an exchange, while retaining all the JBI features (interface based routing, service name based routing or endpoint routing).org.apache.servicemix.eip.support.ExchangeTarget
message-filterA Message Filterorg.apache.servicemix.eip.patterns.MessageFilter
namespace-contextA NamespaceContext implementationorg.apache.servicemix.eip.support.NamespaceContextImpl
pipelineA Pipelineorg.apache.servicemix.eip.patterns.Pipeline
recipient-list-aggregatorAn aggregator specifically written to aggregate messages that have been sent using a StaticRecipientList pattern.org.apache.servicemix.eip.patterns.RecipientListAggregator
resequencerorg.apache.servicemix.eip.patterns.Resequencer
routing-ruleThe RoutingRule interface is used by content based routers. If the rule predicate matches the MessageExchange, the target defined on the rule will be used as the destination for the given MessageExchange.org.apache.servicemix.eip.support.RoutingRule
split-aggregatorAggregator can be used to wait and combine several messages. This component implements the Aggregator pattern. This aggregator collect messages with a count, index and correlationId properties. These properties are automatically set by splitters. A timeout may be specified so that the aggregator will not keep data forever if a message is missing.org.apache.servicemix.eip.patterns.SplitAggregator
static-recipient-listA static Recipient Listorg.apache.servicemix.eip.patterns.StaticRecipientList
static-routing-slipA static Routing Sliporg.apache.servicemix.eip.patterns.StaticRoutingSlip
switch-predicateswitch (on/off) predicate based on a property that can come from 1. a system property 2. a property from a property file (specified as Spring resource) 3. a property from the exchange 4. swtich on/off via JMX MBean (not yet implemented)

the property is interpreted as a boolean value If fromExchange is true --> 3. If propertyResource is specified --> 2. else --> 1.

org.apache.servicemix.eip.support.SwitchPredicate
wire-tapA WireTaporg.apache.servicemix.eip.patterns.WireTap
xpath-predicateorg.apache.servicemix.eip.support.XPathPredicate
xpath-splitterAn XPath Splitterorg.apache.servicemix.eip.patterns.XPathSplitter

Element Detail

Element: async-bridge

AttributeTypeDescription
endpointxs:string
interfaceNamexs:QName
requestCorrIdxs:string
responseCorrIdxs:string
responseCorrIdPropertyxs:string
servicexs:QName
timeoutxs:long
useRobustInOnlyxs:boolean
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
lockManager<spring:bean/>
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: component

ElementTypeDescription
configuration<spring:bean/>
endpoints(async-bridge | content-based-router | content-enricher | message-filter | pipeline | recipient-list-aggregator | resequencer | split-aggregator | static-recipient-list | static-routing-slip | wire-tap | xpath-splitter)*

Element: content-based-router

AttributeTypeDescription
endpointxs:string
interfaceNamexs:QName
servicexs:QName
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
lockManager<spring:bean/>
rules(routing-rule)*
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: content-enricher

AttributeTypeDescription
copyAttachmentsxs:booleanIf this is set to true, message attachments from the incoming exchange and the enricher exchange will be copied to the outgoing message exchange. The default value is false (do not copy message atachments).
copyPropertiesxs:booleanIf this is set to true, message properties from the incoming exchange and the enricher exchange will be copied to the outgoing message exchange. The default value is false (do not copy message properties).
endpointxs:string
enricherElementNamexs:QNamereturns the QName of the resulting root node
interfaceNamexs:QName
requestElementNamexs:QNameReturns the QName of the element which contains the 'IN Message' within the response message
resultElementNamexs:QNameReturns the QName of the element which contains the message which was produced by the enricherTarget within the response message
servicexs:QName
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
enricherTargetexchange-target
lockManager<spring:bean/>
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: default-comparator

AttributeTypeDescription
sequenceNumberAsStringxs:boolean
sequenceNumberKeyxs:string

Element: exchange-target

AttributeTypeDescription
endpointxs:string
interfacexs:QName
operationxs:QName
servicexs:QName
urixs:string

Element: message-filter

AttributeTypeDescription
endpointxs:string
interfaceNamexs:QName
reportErrorsxs:boolean
servicexs:QName
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
filterswitch-predicate | xpath-predicate
lockManager<spring:bean/>
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: namespace-context

ElementTypeDescription
namespaces<spring:bean/>Keep the getter/setter to keep xbean annotation

Element: pipeline

AttributeTypeDescription
copyAttachmentsxs:boolean
copyPropertiesxs:boolean
endpointxs:string
interfaceNamexs:QName
sendFaultsToTargetxs:boolean
servicexs:QName
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
faultsTargetexchange-target
lockManager<spring:bean/>
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
transformerexchange-target
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: recipient-list-aggregator

AttributeTypeDescription
aggregateElementNamexs:QName
copyAttachmentsxs:boolean
copyPropertiesxs:boolean
corrIdxs:string
countxs:string
countAttributexs:string
endpointxs:string
indexxs:string
indexAttributexs:string
interfaceNamexs:QName
messageElementNamexs:QName
reportClosedAggregatesAsErrorsxs:booleanSets whether the aggregator should report errors on incoming exchanges received after a given aggregate has been closed. The default value is false, meaning that such exchanges will be silently sent back with a DONE status and discarded with respect to the aggregation process.
reportErrorsxs:booleanSets whether the aggregator should report errors happening when sending the aggregate on all exchanges that compose the aggregate. The default value is false, meaning that if any error occur, this error will be lost. Note that if this flag is set to true, all exchanges received as part of a given aggregate will be hold until the aggregate is sent and the DONE / ERROR status is received back.
reportTimeoutAsErrorsxs:booleanSets whether the aggregator should reports errors on incoming exchanges already received when a timeout occurs. The default value is false, meaning that such exchanges will be silently sent back a DONE status.
rescheduleTimeoutsxs:boolean
servicexs:QName
synchronousxs:boolean
timeoutxs:long
ElementTypeDescription
closedAggregatesStoreFactory<spring:bean/>Access the currently configured {@link StoreFactory} for storing closed aggregations
definition<spring:bean/>
description<spring:bean/>
lockManager<spring:bean/>
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: resequencer

AttributeTypeDescription
capacityxs:integer
endpointxs:string
interfaceNamexs:QName
servicexs:QName
timeoutxs:long
ElementTypeDescription
comparatordefault-comparator
definition<spring:bean/>
description<spring:bean/>
lockManager<spring:bean/>
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: routing-rule

ElementTypeDescription
predicateswitch-predicate | xpath-predicate
targetexchange-target

Element: split-aggregator

AttributeTypeDescription
aggregateElementNamexs:QName
copyAttachmentsxs:boolean
copyPropertiesxs:boolean
corrIdxs:string
countxs:string
countAttributexs:string
endpointxs:string
indexxs:string
indexAttributexs:string
interfaceNamexs:QName
messageElementNamexs:QName
reportClosedAggregatesAsErrorsxs:booleanSets whether the aggregator should report errors on incoming exchanges received after a given aggregate has been closed. The default value is false, meaning that such exchanges will be silently sent back with a DONE status and discarded with respect to the aggregation process.
reportErrorsxs:booleanSets whether the aggregator should report errors happening when sending the aggregate on all exchanges that compose the aggregate. The default value is false, meaning that if any error occur, this error will be lost. Note that if this flag is set to true, all exchanges received as part of a given aggregate will be hold until the aggregate is sent and the DONE / ERROR status is received back.
reportTimeoutAsErrorsxs:booleanSets whether the aggregator should reports errors on incoming exchanges already received when a timeout occurs. The default value is false, meaning that such exchanges will be silently sent back a DONE status.
rescheduleTimeoutsxs:boolean
servicexs:QName
synchronousxs:boolean
timeoutxs:long
ElementTypeDescription
closedAggregatesStoreFactory<spring:bean/>Access the currently configured {@link StoreFactory} for storing closed aggregations
definition<spring:bean/>
description<spring:bean/>
lockManager<spring:bean/>
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: static-recipient-list

AttributeTypeDescription
endpointxs:string
interfaceNamexs:QName
reportErrorsxs:boolean
servicexs:QName
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
lockManager<spring:bean/>
recipients(exchange-target)*
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: static-routing-slip

AttributeTypeDescription
endpointxs:string
interfaceNamexs:QName
servicexs:QName
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
lockManager<spring:bean/>
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targets(exchange-target)*
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: switch-predicate

AttributeTypeDescription
fromExchangexs:boolean
onxs:boolean
propertyNamexs:string
ElementTypeDescription
propertyResource<spring:bean/>

Element: wire-tap

AttributeTypeDescription
copyPropertiesxs:boolean
endpointxs:string
interfaceNamexs:QName
servicexs:QName
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
faultListenerexchange-target
inListenerexchange-target
lockManager<spring:bean/>
outListenerexchange-target
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>

Element: xpath-predicate

AttributeTypeDescription
XPathxs:string
useMessageContentxs:boolean
xpathxs:string
ElementTypeDescription
factory<spring:bean/>
functionResolver<spring:bean/>
namespaceContextnamespace-context
transformer<spring:bean/>
variableResolver<spring:bean/>

Element: xpath-splitter

AttributeTypeDescription
endpointxs:string
forwardAttachmentsxs:boolean
forwardPropertiesxs:boolean
interfaceNamexs:QName
reportErrorsxs:boolean
servicexs:QName
synchronousxs:boolean
xpathxs:string
ElementTypeDescription
definition<spring:bean/>
description<spring:bean/>
factory<spring:bean/>
functionResolver<spring:bean/>
lockManager<spring:bean/>
namespaceContextnamespace-context
serviceUnit<spring:bean/>
store<spring:bean/>
storeFactory<spring:bean/>
targetexchange-target
timerManager<spring:bean/>
transformer<spring:bean/>
variableResolver<spring:bean/>
wsdlExchangeTargetexchange-target
wsdlResource<spring:bean/>