- Apache Camel Developer's Cookbook
- Table of Contents
- Apache Camel Developer's Cookbook
- Credits
- About the Authors
- Acknowledgments
- About the Reviewers
- www.PacktPub.com
- Preface
- 1. Structuring Routes
- Introduction
- Using Camel in a Java application
- Embedding Camel in a Spring application
- Using Camel components
- Reusing routing logic by connecting routes
- Asynchronously connecting routes
- Spanning Camel contexts within a single Java process
- Using external properties in Camel routes
- Reusing endpoints
- Reusing routing logic through template routes
- Controlling route startup and shutdown
- 2. Message Routing
- Introduction
- Content Based Routing
- Filtering out unwanted messages
- Wire Tap – sending a copy of the message elsewhere
- Multicast – routing the same message to many endpoints
- Recipient List – routing a message to a list of endpoints
- Throttler – restricting the number of messages flowing to an endpoint
- Request-response route sending a one-way message
- One-way route waiting on a request-response endpoint
- Dynamic Routing – making routing decisions at runtime
- Load balancing across a number of endpoints
- Routing Slip – routing a message to a fixed list of endpoints
- 3. Routing to Your Code
- 4. Transformation
- Introduction
- Transforming using a Simple Expression
- Transforming inline with XQuery
- Transforming with XSLT
- Transforming from Java to XML with JAXB
- Transforming from Java to JSON
- Transforming from XML to JSON
- Parsing comma-separated values (CSV)
- Enriching your content with some help from other endpoints
- Normalizing messages into a common XML format
- 5. Splitting and Aggregating
- Introduction
- Splitting a message into fragments
- Splitting XML messages
- Processing split messages in parallel
- Aggregating related messages
- Aggregating with timeouts
- Aggregating with intervals
- Processing aggregated messages in parallel
- Splitting a message, and processing and gathering responses
- Splitting messages and re-aggregating them using different criteria
- 6. Parallel Processing
- 7. Error Handling and Compensation
- Introduction
- Logging errors
- Dead Letter Channel – handling errors later
- Retrying an operation
- Conditional retry
- Customizing each redelivery attempt
- Catching exceptions
- Marking exceptions as handled
- Fine-grained error handling using doTry…doCatch
- Defining completion actions
- Defining completion actions dynamically
- 8. Transactions and Idempotency
- Introduction
- Preventing duplicate invocation of routing logic
- Transactional file consumption
- Using transactions with a database
- Limiting the scope of a transaction
- Rolling back a transaction
- Using transactions with messaging
- Idempotency inside transactions
- Setting up XA transactions over multiple transactional resources
- 9. Testing
- Introduction
- Testing routes defined in Java
- Using mock endpoints to verify routing logic
- Replying from mock endpoints
- Testing routes defined in Spring
- Testing routes defined in OSGi Blueprint
- Auto-mocking of endpoints
- Validating route behavior under heavy load
- Unit testing processors and Bean Bindings
- Testing routes with fixed endpoints using AOP
- Testing routes with fixed endpoints using conditional events
- 10. Monitoring and Debugging
- Introduction
- Logging meaningful steps within your route
- Debugging using logging
- Throughput logging
- Enabling step-by-step tracing in code
- Disabling JMX
- Configuring JMX
- Naming your routes to make it easier to monitor
- Adding JMX attributes and operations
- Monitoring other systems using the Camel JMX Component
- Setting breakpoints in your routes
- 11. Security
- 12. Web Services
- Index
In this chapter, we will cover:
- Splitting a message into fragments
- Splitting XML messages
- Processing split messages in parallel
- Aggregating related messages
- Aggregating with timeouts
- Aggregating with intervals
- Processing aggregated messages in parallel
- Splitting a message, and processing and gathering responses
- Splitting messages and re-aggregating them using different criteria
This chapter will describe how to split exchanges into smaller fragments and process them individually. It will also explain how you can aggregate (join) multiple exchanges by grouping them according to arbitrary expressions. Finally, it will discuss how to split messages into fragments, process them individually, and re-aggregate the results; either back into the original exchange, or into a new combination of exchanges.
None of these operations are as straightforward as might be considered at first glance. The combination of options that you select alters behaviors such as error handling and threading quite substantially. The following recipes will explain some of these edge cases.
A number of Camel architectural concepts are used throughout this chapter. There is a broader overview of Camel concepts in the Preface. Full details can be found on the Apache Camel website at http://camel.apache.org.
The code for this chapter is contained within the camel-cookbook-split-join module of the examples.
-
No Comment