Fuse 6 is no longer supported
As of February 2025, Red Hat Fuse 6 is no longer supported. If you are using Fuse 6, please upgrade to Red Hat build of Apache Camel.此内容没有您所选择的语言版本。
A.7. Pipeline
Overview 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
The ServiceMix EIP pipeline pattern, shown in Figure A.4, “Pipes and Filters Pattern”, is used to pass messages through a single transformer endpoint, where the transformer's input is taken from the source endpoint and the transformer's output is routed to the target endpoint. This pattern is thus a special case of the more general Apache Camel pipes and filters pattern, which enables you to pass an In message through multiple transformer endpoints.
Figure A.4. Pipes and Filters Pattern
Example ServiceMix EIP route 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
Example A.10, “ServiceMix EIP Pipeline” shows how to define a pipeline using the ServiceMix EIP component. Incoming messages are passed into the transformer endpoint,
test:decrypt
, and the output from the transformer endpoint is then passed into the target endpoint, test:plaintextOrder
.
Example A.10. ServiceMix EIP Pipeline
Equivalent Apache Camel XML route 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
Example A.11, “Apache Camel Pipeline Using XML” shows how to define an equivalent route using Apache Camel XML configuration.
Example A.11. Apache Camel Pipeline Using XML
<route> <from uri="jbi:endpoint:http://progress.com/demos/test/pipeline/endpoint"/> <to uri="jbi:service:http://progress.com/demos/test/decrypt"/> <to uri="jbi:service:http://progress.com/demos/test/plaintextOrder"/> </route>
<route>
<from uri="jbi:endpoint:http://progress.com/demos/test/pipeline/endpoint"/>
<to uri="jbi:service:http://progress.com/demos/test/decrypt"/>
<to uri="jbi:service:http://progress.com/demos/test/plaintextOrder"/>
</route>
Equivalent Apache Camel Java DSL route 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
Example A.12, “Apache Camel Pipeline Using Java DSL” shows how to define an equivalent route using the Apache Camel Java DSL.
Example A.12. Apache Camel Pipeline Using Java DSL
from("jbi:endpoint:http://progress.com/demos/test/pipeline/endpoint"). pipeline("jbi:service:http://progress.com/demos/test/decrypt", "jbi:service:http://progress.com/demos/test/plaintextOrder");
from("jbi:endpoint:http://progress.com/demos/test/pipeline/endpoint").
pipeline("jbi:service:http://progress.com/demos/test/decrypt", "jbi:service:http://progress.com/demos/test/plaintextOrder");