Apache Camel is a powerful open-source integration framework based on known Enterprise Integration Patterns (EIP). It provides a versatile set of tools to integrate various systems, APIs, and protocols seamlessly. Integrating Apache Camel with Spring Boot makes it easier to create standalone applications that can handle complex routing and mediation scenarios. This tutorial will guide you through the process of setting up Apache Camel with Spring Boot.
Prerequisites
- JDK 17 or later
- Maven or Gradle
- IDE (IntelliJ IDEA, Eclipse, etc.)
Step 1: Set Up a Spring Boot Project
1.1 Create a New Spring Boot Project
Use Spring Initializr to create a new project with the following dependencies:
Download and unzip the project, then open it in your IDE.
1.2 Add Apache Camel Dependencies
If you didn't add the Apache Camel dependency via Spring Initializr, add the following dependencies to your pom.xml
(for Maven) or build.gradle
(for Gradle).
For Maven:
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
<version>3.16.0</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
<version>3.16.0</version>
</dependency>
For Gradle:
implementation 'org.apache.camel.springboot:camel-spring-boot-starter:3.16.0'
implementation 'org.apache.camel:camel-core:3.16.0'
Step 2: Configure Apache Camel in Spring Boot
2.1 Create a Simple Camel Route
Create a Camel route by defining a route builder class. This class will define how messages are routed from one endpoint to another.
package com.example.demo.routes;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@Component
public class SimpleRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
from("timer:hello?period=1000")
.log("Hello from Camel!")
.to("stream:out");
}
}
Explanation:
@Component
: Marks this class as a Spring component.
RouteBuilder
: A base class for creating Camel routes.
from("timer:hello?period=1000")
: A timer endpoint that triggers every second (1000 milliseconds).
log("Hello from Camel!")
: Logs a message to the console.
to("stream:out")
: Sends the output to the standard output stream (console).
2.2 Configure application.properties
Set up the application properties for your project. This file is located in the src/main/resources
directory.
# src/main/resources/application.properties
camel.springboot.name=camel-spring-boot-demo
camel.springboot.main-run-controller=true
camel.springboot.routes-collector-enabled=true
Explanation:
camel.springboot.name
: Sets the name of the Camel application.
camel.springboot.main-run-controller=true
: Allows the application to keep running.
camel.springboot.routes-collector-enabled=true
: Enables route collection from the Spring context.
Step 3: Create a REST Endpoint Using Camel
3.1 Create a REST Route
Create a new Camel route to handle REST requests.
package com.example.demo.routes;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@Component
public class RestRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
restConfiguration().component("servlet").port(8080).bindingMode(RestBindingMode.json);
rest("/api")
.get("/hello")
.to("direct:helloRoute");
from("direct:helloRoute")
.setBody(constant("Hello, World from Apache Camel!"))
.log("Processed REST request to /api/hello");
}
}
Explanation:
restConfiguration().component("servlet").port(8080).bindingMode(RestBindingMode.json)
: Configures the REST component to use the servlet container on port 8080 with JSON binding.
rest("/api").get("/hello").to("direct:helloRoute")
: Defines a REST endpoint at /api/hello
that routes requests to direct:helloRoute
.
from("direct:helloRoute").setBody(constant("Hello, World from Apache Camel!")).log("Processed REST request to /api/hello")
: Sets up the route to handle requests by setting a constant response body and logging the request.
Step 4: Create a Main Application Class
Ensure your main application class is annotated with @SpringBootApplication
.
package com.example.demo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
}
Step 5: Running and Testing the Application
5.1 Run the Application
Run the Spring Boot application using your IDE or the command line:
./mvnw spring-boot:run
5.2 Test the Timer Route
Check the console output to see the log messages from the timer route. You should see "Hello from Camel!" logged every second.
5.3 Test the REST Endpoint
Open your browser or use a tool like Postman to test the REST endpoint.
- URL:
http://localhost:8080/api/hello
- Method: GET
You should see the following response:
"Hello, World from Apache Camel!"
Step 6: Advanced Camel Features (Optional)
6.1 Using a File Component
You can use the file component to read from and write to files.
package com.example.demo.routes;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@Component
public class FileRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
from("file:input?noop=true")
.log("Reading file: ${file:name}")
.to("file:output");
}
}
Explanation:
from("file:input?noop=true")
: Reads files from the input
directory without deleting them.
log("Reading file: ${file:name}")
: Logs the name of the file being read.
to("file:output")
: Writes the files to the output
directory.
6.2 Using a JMS Component
You can use the JMS component to send and receive messages from a JMS queue.
package com.example.demo.routes;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@Component
public class JmsRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
from("jms:queue:inputQueue")
.log("Received message: ${body}")
.to("jms:queue:outputQueue");
}
}
Explanation:
from("jms:queue:inputQueue")
: Reads messages from the inputQueue
.
log("Received message: ${body}")
: Logs the message body.
to("jms:queue:outputQueue")
: Sends the messages to the outputQueue
.
Conclusion
In this tutorial, you have learned how to integrate Apache Camel with Spring Boot to create a flexible and powerful integration solution. We covered:
- Setting up a Spring Boot project with Apache Camel.
- Creating simple and REST-based Camel routes.
- Running and testing the application.
By leveraging Apache Camel's powerful integration capabilities within a Spring Boot application, you can handle complex routing and mediation scenarios with ease.
Related Spring Boot Source Code Examples
Spring Boot Security Login REST API Example
Spring Boot Security Login and Registration REST API
Role-based Authorization using Spring Boot and Spring Security
Spring Boot JWT Authentication and Authorization Example
Spring Boot Security JWT Example - Login REST API with JWT Authentication
Spring Boot DTO Example
Spring Boot DTO ModelMapper Example
@GetMapping Spring Boot Example
@PostMapping Spring Boot Example
@PutMapping Spring Boot Example
@DeleteMapping Spring Boot Example
@PatchMapping Spring Boot Example
@SpringBootApplication - Spring Boot
Spring Boot Hello World REST API Example
Spring Boot REST API returns Java Bean
Create Spring Boot REST API returns List
Spring Boot REST API with Path Variable
Spring Boot REST API with Request Param
Spring Boot Hibernate MySQL CRUD REST API Tutorial
Spring Boot Real-Time Project Development using Spring MVC + Spring Security + Thymeleaf and MySQL Database
Spring Boot Tutorial - User Login and Registration Backend + Email Verification
Spring Boot JUnit and Mockito Example - Service Layer Testing
Spring Professional Certification Cost
Spring Boot Validate JSON Request Body
Spring Boot One to Many CRUD Example | REST Controller
Spring Boot Project with Controller Layer + Service Layer + Repository/DAO Layer
Spring Boot Reactive MongoDB CRUD Example - WebFlux
Spring Boot Amazon S3 - File Upload Download Delete Example
Spring Boot RabbitMQ Publisher and Consumer Example
Free Spring Boot Open Source Projects for Learning Purposes
Spring Boot + Microsoft SQL Server + Hibernate Example
Spring Boot Hibernate Thymeleaf MySQL CRUD Example
Spring Boot CRUD Example with Spring MVC, Spring Data JPA, ThymeLeaf, Hibernate, MySQL
Spring Boot Hibernate RESTful GET POST PUT and DELETE API Tutorial
Best YouTube Channels to learn Spring Boot
React Spring Boot Example
Spring Boot Groovy Thymeleaf Example Tutorial
Spring Boot Scala Thymeleaf Example Tutorial
Spring Boot Hibernate DAO with MySQL Database Example
Spring Boot PostgreSQL CRUD Example
Spring Boot CRUD Example with MySQL
Spring Boot Starter Parent
Spring Boot JdbcTemplate Example
Spring Boot PayPal Payment Gateway Integration Example
Create Spring Boot REST API
How to Create Spring Boot Application Using Maven
How to Create Spring Boot Application Using Gradle
How to Use Thymeleaf in a Spring Boot Web Application?
How to Enable CORS in a Spring Boot Application?
Spring Boot + Angular 8 CRUD Example
Spring Boot + Angular 9 CRUD Example
Spring Boot + Angular + WebSocket Example
Spring Boot CRUD Application with Thymeleaf
Spring Boot ReactJS CRUD Project - Employee Management App | GitHub
Spring Petclinic ReactJS Project | GitHub
Spring Boot React JWT Authentication Example
Spring Boot React Basic Authentication Example
CRUD Example using Spring Boot + Angular + MySQL
Spring Boot + React + Redux CRUD Example
Spring Boot Project - Sagan
Spring Boot Project - ReactJS Spring Boot CRUD Full Stack Application - GitHub
Spring Boot Project - Spring Initializr
Spring Boot + Angular Project - Employee Management System
Spring Boot Thymeleaf Project - Employee Management System
Spring Boot MVC Project - Blogs Aggregator
Spring Boot Project - Spring Petclinic | GitHub
Spring Boot, Spring Cloud Microservice Project - PiggyMetrics | GitHub
Spring Boot, Spring Security, JWT, React, and Ant Design - Polling App | GitHub
Spring Boot Microservice Project - Shopping Cart App | GitHub
Spring Boot, Spring Cloud Microservice Project - Spring Petclinic App | GitHub
Microservices with Spring Cloud Project | GitHub
Spring Boot Angular Petclinic Project | GitHub
Spring Boot Angular Project - BookStore App | GitHub
React Springboot Microservices Project | GitHub
Spring Boot Microservices, Spring Cloud, and React Project - BookStoreApp | GitHub
Spring Boot + Spring Security + JWT Example
Spring Boot Hibernate Assign UUID Identifiers Example
Spring Boot Angular Project - Reddit Clone Application
Spring Boot Step-by-Step Example
Spring Boot Starters List
Spring Boot E-Commerce Project - Shopizer
Spring Data JPA - save() Method Example
Spring Data JPA - saveAll() Method Example
Spring Data JPA - findById() Method Example
Spring Data JPA - findAll() Method Example
Spring Data JPA - count() Method Example
Spring Data JPA - deleteById() Method Example
Spring Data JPA - delete() Method Example
Spring Data JPA - deleteAll() Method Example
Spring Data JPA - Distinct Query Method Example
Spring Data JPA - GreaterThan Query Method Example
Spring Data JPA - LessThan Query Method Example
Spring Data JPA - Containing Query Method Example
Spring Data JPA - Like Query Method Example
Spring Data JPA - Between Query Method Example
Spring Data JPA - Date Range Between Query Method Example
Spring Data JPA - In Clause Query Method Example
Unit Test Spring Boot GET REST API using JUnit and Mockito
Unit Test Spring Boot POST REST API using JUnit and Mockito
Unit Test Spring Boot PUT REST API using JUnit and Mockito
Unit Test Spring Boot DELETE REST API using JUnit and Mockito
Create REST Client using WebClient for Spring Boot CRUD REST API
Spring Boot WebClient GET Request with Parameters
Spring Boot WebClient POST Request Example
Spring Boot WebClient PUT Request Example
Spring Boot WebClient DELETE Request Example
Spring Boot RestClient GET Request Example
Spring Boot RestClient POST Request Example
Spring Boot RestClient PUT Request Example
Spring Boot RestClient Delete Request Example
Spring Core Annotations with Examples
Spring Boot @Component Example
Spring Boot @Autowired Example
Spring Boot @Qualifier Example
Spring Boot @Primary Example
Spring Boot @Bean Example
Spring Boot @Lazy Example
Spring Boot @Scope Example
Spring Boot @PropertySource Example
Spring Boot @Transactional Example
Spring Boot @Configuration Example
Spring Boot @ComponentScan Example
Spring Boot @Profile Example
Spring Boot @Cacheable Example
Spring Boot @DependsOn Example
Spring Boot @RestController Example
Spring Boot @ResponseBody Example
Spring Boot @GetMapping Example
Spring Boot @PostMapping Example
Spring Boot @PutMapping Example
Spring Boot @DeleteMapping Example
Spring Boot @PatchMapping Example
Spring Boot @PathVariable Example
Spring Boot @ResponseStatus Example
Spring Boot @Service Example
Spring Boot @Repository Example
Spring Boot @RequestParam Example
Spring Boot @SessionAttribute Example
Spring Boot @RequestBody Example
Spring Boot @ExceptionHandler Example
Spring Boot @InitBinder Example
Spring Boot @ModelAttribute Example
Spring Boot @RequestMapping Example
Spring Boot @CrossOrigin Example
Spring Boot @ControllerAdvice Example
Spring Boot @RestControllerAdvice Example
Spring Boot @SpringBootApplication Example
Spring Boot @EnableAutoConfiguration Example
Spring Boot @ConditionalOnClass Example
Spring Boot @SpringBootConfiguration Example
Spring Boot @ConditionalOnProperty Example
Spring Boot @ConditionalOnWebApplication Example
Spring Boot @ConfigurationProperties Example
Spring Boot @Async Example
Spring Boot @Scheduled Example
Spring Boot @SpringBootTest Example
Spring Boot @WebMvcTest Example
Spring Boot @DataJpaTest Example
Spring Boot @EnableDiscoveryClient Example
Spring Boot @EnableFeignClients Example
Spring Boot @RefreshScope Example
Spring Boot @LoadBalanced Example
Spring Boot @Query Example
Spring Boot @Modifying Example
Spring Boot @Param Example
Spring Boot JPA @Transient Example
Spring Boot JPA @Enumerated Example
Spring Boot JPA @Temporal Example
Spring Boot @CreatedBy Example
Spring Boot @LastModifiedDate Example
Spring Boot @IdClass Example
Spring Boot
Comments
Post a Comment