Add message-service demo application

Author: asaikali

eureka-server/src/main/resources/application.yml

@@ -2,4 +2,11 @@
 server:
   port: 8761
 
-spring.cloud.ser
+eureka:
+  client:
+    register-with-eureka: false
+    fetch-registry: false
+  # set the info about where this eureka server is running useful to set when
+  # running eureka across availability zones and regions
+  datacenter: laptop
+  environment: dev

message-service/pom.xml

@@ -0,0 +1,65 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<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">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.example</groupId>
+    <artifactId>message-service</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <packaging>jar</packaging>
+
+    <name>message-service</name>
+    <description>Demo project showing how to register a service with Eureka</description>
+
+    <parent>
+        <groupId>com.example</groupId>
+        <artifactId>spring-cloud-eureka-basics</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.flywaydb</groupId>
+            <artifactId>flyway-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+            <plugin>
+                <groupId>pl.project13.maven</groupId>
+                <artifactId>git-commit-id-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

message-service/src/main/java/com/example/messageservice/MessageController.java

@@ -0,0 +1,43 @@
+package com.example.messageservice;
+
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.Optional;
+
+@RestController
+public class MessageController {
+
+    private final QuoteRepository quoteRepository;
+
+    public MessageController(QuoteRepository quoteRepository) {
+        this.quoteRepository = quoteRepository;
+    }
+
+    @GetMapping("/")
+    public Quote radomQuote()
+    {
+        return quoteRepository.findRandomQuote();
+    }
+
+    @GetMapping("/quotes")
+    public List<Quote> getAll()
+    {
+        return quoteRepository.findAll();
+    }
+
+    @GetMapping("/quotes/{id}")
+    public ResponseEntity<Quote> getQuote(@PathVariable("id") Integer id) {
+        Optional<Quote> quote = quoteRepository.findById(id);
+        if (quote.isPresent()) {
+            return new ResponseEntity<>(quote.get(), HttpStatus.OK);
+        } else {
+            return new ResponseEntity<>(HttpStatus.NOT_FOUND);
+        }
+    }
+}

message-service/src/main/java/com/example/messageservice/MessageServiceApplication.java

@@ -0,0 +1,14 @@
+package com.example.messageservice;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+
+@EnableDiscoveryClient
+@SpringBootApplication
+public class MessageServiceApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(MessageServiceApplication.class, args);
+    }
+}

message-service/src/main/java/com/example/messageservice/Quote.java

@@ -0,0 +1,45 @@
+package com.example.messageservice;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "quotes")
+public class Quote
+{
+    @Id
+    @Column(name = "id")
+    private Integer id;
+
+    @Column(name="quote")
+    private String quote;
+
+    @Column(name="author")
+    private String author;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getQuote() {
+        return quote;
+    }
+
+    public void setQuote(String quote) {
+        this.quote = quote;
+    }
+
+    public String getAuthor() {
+        return author;
+    }
+
+    public void setAuthor(String author) {
+        this.author = author;
+    }
+}

message-service/src/main/java/com/example/messageservice/QuoteRepository.java

@@ -0,0 +1,11 @@
+package com.example.messageservice;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+
+public interface QuoteRepository extends JpaRepository<Quote,Integer> {
+
+    @Query( nativeQuery = true, value =
+            "SELECT id,quote,author FROM quotes ORDER BY RANDOM() LIMIT 1")
+    Quote findRandomQuote();
+}

message-service/src/main/resources/application.yml

@@ -0,0 +1,25 @@
+# Set this service to start on a random port number that is not being
+# used, this will allow us to launch multiple versions of the service
+# and register them with Eureka for discovery
+server:
+  port: 0
+
+eureka:
+  client:
+    fetch-registry: false # This service does not call any other service so no need to cache list of registered services
+    register-with-eureka: true # This service should register itself in eureka
+  instance:
+    instance-id: ${spring.application.name}:${random.int} # unique id for app instances registered with eureka
+
+# expose all the spring boot actuators good for demos.
+# NEVER DO THIS in production
+management:
+  endpoints:
+    web:
+      exposure:
+        include: "*"
+  endpoint:
+    health:
+      show-details: always
+
+

message-service/src/main/resources/bootstrap.yml

@@ -0,0 +1,3 @@
+spring:
+  application:
+    name: message-service

message-service/src/main/resources/db/migration/V1__create_quotes_table.sql

@@ -0,0 +1,11 @@
+CREATE TABLE quotes(
+  id INTEGER PRIMARY KEY,
+  quote VARCHAR(1024),
+  author VARCHAR(256)
+);
+
+INSERT INTO quotes (id,quote,author) VALUES (1,'Never, never, never give up','Winston Churchill');
+INSERT INTO quotes (id,quote,author) VALUES (2,'While there''s life, there''s hope','Marcus Tullius Cicero');
+INSERT INTO quotes (id,quote,author) VALUES (3,'Failure is success in progress','Anonymous');
+INSERT INTO quotes (id,quote,author) VALUES (4,'Success demands singleness of purpose','Vincent Lombardi');
+INSERT INTO quotes (id,quote,author) VALUES (5,'The shortest answer is doing','Lord Herbert');

message-service/src/test/java/com/example/messageservice/MessageServiceApplicationTests.java

@@ -0,0 +1,16 @@
+package com.example.messageservice;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class MessageServiceApplicationTests {
+
+    @Test
+    public void contextLoads() {
+    }
+
+}