This example demonstrates how to write a pub/sub application using Spring JMS and Oracle Database Transactional Event Queues. If you're unfamiliar with Transactional Event Queues, it is a high-throughput, distributed asynchronous messaging system built into Oracle Database. The integration of Transactional Event Queues with Spring JMS provides a simple interface for rapid development of messaging applications.
The Spring Boot Starter for AQ/JMS used in the example pulls in all necessary dependencies to use Spring JMS with Oracle Database Transactional Event Queues, requiring minimal configuration.
For an in-depth walkthough of Spring JMS with Transactional Event Queues, see the following guide: Use JMS for asynchronous messaging in Spring Boot.
- Java 21+, Maven
- Docker compatible environment
The sample provides an all-in-one test leveraging Testcontainers and Oracle Database to do the following:
- Start and configure a database server using Testcontainers
- Produce several messages to a Transactional Event Queue using an autowired JMSTemplate.
- Verify all messages are consumed by the JMSListener.
You can run the test like so, from the project's root directory:
mvn test
You should see output similar to the following:
Starting Spring Boot JMS Example
Produced 5 messages to the queue via JMS.
Waiting for consumer to finish processing messages...
Received message: test message 1
Received message: test message 2
Received message: test message 3
Received message: test message 4
Received message: test message 5
Consumer finished.