The goal of this project is to create an application that produces and consumes delayed messages randomly. Those messages are sent to ActiveMQ or RabbitMQ. The delayed broker to which the message is sent depends on a feature toggle defined in Unleash.

On ivangfr.github.io, I have compiled my Proof-of-Concepts (PoCs) and articles. You can easily search for the technology you are interested in by using the filter. Who knows, perhaps I have already implemented a PoC or written an article about what you are looking for.

delayed-message-producer-consumer is a Spring Boot Java application that produces and consumes messages with random delays.

These delayed messages are sent to ActiveMQ or RabbitMQ brokers.

However, both brokers are not ready to handle delayed messages by default. For it, we needed to enable the scheduler in ActiveMQ and, in RabbitMQ, we install the Delayed Message Plugin.

Furthermore, in order to easily switch the delayed message broker to where the messages are sent without restarting the application, we use a feature toggle called rabbitMQEnabled that is defined in Unleash.

• Java 17+
• Docker
• Docker-Compose

Open a terminal and inside springboot-activemq-rabbitmq-delayed-messages root folder run

./init-environment.sh

Note: this script, besides starting ActiveMQ, RabbitMQ, Unleash and Postgres, it will create in Unleash a feature toggle called rabbitMQEnabled.

• In a terminal, make sure you are inside springboot-activemq-rabbitmq-delayed-messages folder
• Run the following command

  ./mvnw clean spring-boot:run --projects delayed-message-producer-consumer \
    -Dspring-boot.run.jvmArguments="-Dunleash.api.key='*:development.some-random-string'"
  

  Note: the UNLEASH_API_KEY was created during the step Initialize Environment

• Build Docker image

  • In a terminal, make sure you are inside springboot-activemq-rabbitmq-delayed-messages root folder
  • Run the following script

    ./docker-build.sh
    

• Environment variables

• Start Docker container

  • In a terminal, run the following command

    docker run --rm --name delayed-message-producer-consumer \
      -e ACTIVEMQ_BROKER_URL=tcp://activemq:61616 \
      -e RABBITMQ_ADDRESSES=rabbitmq:5672 \
      -e UNLEASH_API_URL=http://unleash:4242/api \
      -e UNLEASH_API_KEY='*:development.some-random-string' \
      --network=springboot-activemq-rabbitmq-delayed-messages_default \
      ivanfranchin/delayed-message-producer-consumer:1.0.0
    

    Note: the UNLEASH_API_KEY was created during the step Initialize Environment

  • [Optional] To start a 2nd Docker container, in another terminal, run the command below

    docker run --rm --name delayed-message-producer-consumer-2 \
      -e ACTIVEMQ_BROKER_URL=tcp://activemq:61616 \
      -e RABBITMQ_ADDRESSES=rabbitmq:5672 \
      -e UNLEASH_API_URL=http://unleash:4242/api \
      -e UNLEASH_API_KEY='*:development.some-random-string' \
      --network=springboot-activemq-rabbitmq-delayed-messages_default \
      ivanfranchin/delayed-message-producer-consumer:1.0.0
    

• Access Unleash website at http://localhost:4242
• To login, type admin and unleash4all for username and password, respectively;
• In Projects page, select Default;
• You should see the rabbitMQEnabled feature toggle;
• The API token provided to delayed-messages-producer-consumer, was created to development environment. So, if the development checkbox is enabled, the messages will be sent to RabbitMQ; otherwise, they will go to ActiveMQ.

• ActiveMQ

  • Access http://localhost:8161
  • Click Manage ActiveMQ broker
  • To login, type admin for both username and password

• RabbitMQ

  • Access http://localhost:15672
  • To login, type admin for both username and password

• Unleash

  • Access http://localhost:4242
  • To login, type admin and unleash4all for username and password, respectively

• To stop delayed-message-producer-consumer application, go to the terminal where it is running and press Ctrl+C
• To stop and remove docker-compose containers, network and volumes, go to a terminal and, inside springboot-activemq-rabbitmq-delayed-messages root folder, run the following command

  ./shutdown-environment.sh
  

To remove the Docker image create by this project, go to a terminal and, inside springboot-activemq-rabbitmq-delayed-messages root folder, run the following script

./remove-docker-images.sh