Pivotal Cloud Foundry Tutorial - Deploying Spring Boot + RabbitMQ Application to PCF | JavaInUse

Pivotal Cloud Foundry Tutorial - Deploying Spring Boot + RabbitMQ Application to PCF

In previous tutorial we had deployed a Spring Boot + MySQL application to PCF. Let us now look at some PCF concepts like Orgs, Spaces.
In this tutorial we will develop a Spring Boot + RabbitMQ Application and deploy it to PCF.
Spring Boot RabbitMQ CF Push

Pivotal Cloud Foundry - Table Of Contents

Pivotal Cloud Foundry Tutorial - Quick Introduction Pivotal Cloud Foundry Tutorial - Setting up the Development Environment Pivotal Cloud Foundry Tutorial - Deploy Spring Boot Application Hello World Example Pivotal Cloud Foundry Tutorial - Understanding PCF Deployment Architecture Pivotal Cloud Foundry Tutorial - Deploying Spring Boot + MySQL Application to PCF Pivotal Cloud Foundry Tutorial - Deploying Spring Boot + RabbitMQ Application to PCF

Lets Begin-

In a previous post we had seen how to get RabbitMQ up and running.
Spring Boot RabbitMQ Tutorial The project will be as follows-
Spring Boot RabbitMQ Eclipse Setup
Define the pom.xml as follows- Add the spring-boot-starter-amqp dependency.
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">


		<relativePath />




Define the domain class Employee as follows-
package com.javainuse.model;

import com.fasterxml.jackson.annotation.JsonIdentityInfo;
import com.fasterxml.jackson.annotation.ObjectIdGenerators;

@JsonIdentityInfo(generator = ObjectIdGenerators.IntSequenceGenerator.class, property = "@id", scope = Employee.class)
public class Employee {

	private String empName;
	private String empId;

	public String getEmpName() {
		return empName;

	public void setEmpName(String empName) {
		this.empName = empName;

	public String getEmpId() {
		return empId;

	public void setEmpId(String empId) {
		this.empId = empId;

	public String toString() {
		return "Employee [empName=" + empName + ", empId=" + empId + "]";

Next define the configuration as follows-
package com.javainuse.config;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

public class RabbitMQConfig {

	String queueName;

	String exchange;

	private String routingkey;

	Queue queue() {
		return new Queue(queueName, false);

	DirectExchange exchange() {
		return new DirectExchange(exchange);

	Binding binding(Queue queue, DirectExchange exchange) {
		return BindingBuilder.bind(queue).to(exchange).with(routingkey);

	public MessageConverter jsonMessageConverter() {
		return new Jackson2JsonMessageConverter();

	public AmqpTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
		final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
		return rabbitTemplate;
Define the Controller to expose a GET Request API as follows-
package com.javainuse.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import com.javainuse.model.Employee;
import com.javainuse.service.RabbitMQSender;

@RequestMapping(value = "/javainuse-rabbitmq/")
public class RabbitMQWebController {

	RabbitMQSender rabbitMQSender;

	@GetMapping(value = "/producer")
	public String producer(@RequestParam("empName") String empName,@RequestParam("empId") String empId) {
	Employee emp=new Employee();

		return "Message sent to the RabbitMQ JavaInUse Successfully";


Define the RabbitMQSender class which sends the message to the RabbitMQ using AmqpTemplate. We use the exchange and the exchange key.
Exchanges are message routing agents, defined per virtual host within RabbitMQ. An exchange is responsible for the routing of the messages to the different queues. An exchange accepts messages from the producer application and routes them to message queues with help of header attributes, bindings, and routing keys.
We will use a direct exchange instead. The routing algorithm behind a direct exchange is simple - a message goes to the queues whose binding key exactly matches the routing key of the message.
package com.javainuse.service;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import com.javainuse.model.Employee;

public class RabbitMQSender {
	private AmqpTemplate rabbitTemplate;
	private String exchange;
	private String routingkey;	
	public void send(Employee company) {
		rabbitTemplate.convertAndSend(exchange, routingkey, company);
		System.out.println("Send msg = " + company);
Next define th following properties in application.properties-
Finally Define the Spring Boot Class with @SpringBootApplication annotation
package com.javainuse;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

public class SpringBootHelloWorldApplication {

	public static void main(String[] args) {

				new Object[] { SpringBootHelloWorldApplication.class }, args);

We are done with the required Java code. Now lets start RabbitMQ. As we had explained in detail in the Getting started with RabbitMQ perform the steps to start the RabbitMQ.
Next start the Spring Boot Application by running it as a Java Application. Hit the url as follows- http://localhost:8080/javainuse-rabbitmq/producer?empName=emp1&empId=emp001
Spring Boot RabbitMQ Example
This will trigger the message to be sent to the javainuse queue.
Next go to the RabbitMQ console-http://localhost:15672/
Spring Boot RabbitMQ Consoler
We can see in the Queues section, a queue name java gets created and it has one message.
Spring Boot RabbitMQ Queue

PCF Deployment-

In Cloud Foundry, services are on demand resources that users can provision and use for their deployed application.
Examples of resources services provide include databases on a shared or dedicated server, or accounts on a SaaS application. These resources are known as service instances and the systems that deliver and operate these resources are known as Services. Think of a service as a factory that delivers service instances.
Services can either be
  • User Defined Service
  • MarketPlace Service
For this example we will be needing the RabbitMQ MarketPlace service.
PCF market services

Provisioning RabbitMQ Service using PCF Web Console

  • Login to Pivotal Cloud Foundry with your credentials
    Pivotal Web Services Home
  • Go to Services tab for our development space
    Cloud Foundry Services
  • Select ClearDB MySql
    PCF RabbitMQ Service
  • Select the free plan free Spark DB.
    PCF RabbitMQ Service Lemur Free
    Name the service as rabbitMQService.

Creating Manifest Configuration file to Bind our Maven Project to PCF SQL Service

In our eclipse jdbc project create a manifest configuration file as follows-
name: SpringBootRabbitMq
path: target\SpringBootRabbitMQHelloWorld-0.0.1-SNAPSHOT.jar
memory: 1G
  - rabbitmqservice

Push the application to PCF

  • Open the command terminal and use the following command
         cf login

    Cloud Foundry Login
  • It will ask for Cloud Foundry API. Enter The following API value-

    Cloud Foundry Login API
  • Next it will ask you for the Cloud Foundry credentials
    Cloud Foundry Credentials
  • Use the command cf push-
         cf push

    Spring Boot RabbitMQ Push
The application is deployed on PCF. Go the PCF Web Console. Our new application will be up and running.
Spring Boot RabbitMQ Running App
Select the application and go to the specified route. Append javainuse-rabbitmq/producer?empName=emp1&empId=emp001 to the route url. Our application is up and running.
Spring Boot RabbitMQ Output

Download Source Code

Download it -
PCF- Spring Boot+RabbitMQ