RabbitMQ Installation Instructions

sankhaonline · Sep 11, 2017 · a2b4ee3 · a2b4ee3
1 parent 1850ee9
commit a2b4ee3
Show file tree

Hide file tree

Showing 14 changed files with 65 additions and 55 deletions.
diff --git a/03.microservices/currency-conversion-service/pom.xml b/03.microservices/currency-conversion-service/pom.xml
@@ -26,10 +26,6 @@
  </properties>
 
  <dependencies>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-actuator</artifactId>
- </dependency>
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-config</artifactId>
@@ -40,6 +36,11 @@
  <artifactId>spring-cloud-starter-feign</artifactId>
  </dependency>
 
+ <dependency>
+ <groupId>org.springframework.cloud</groupId>
+ <artifactId>spring-cloud-starter-sleuth</artifactId>
+ </dependency>
+
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-eureka</artifactId>
@@ -55,11 +56,6 @@
  <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
 
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-devtools</artifactId>
- <scope>runtime</scope>
- </dependency>
  <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>

diff --git a/...com/in28minutes/microservices/currencyconversionservice/CurrencyConversionController.java b/...com/in28minutes/microservices/currencyconversionservice/CurrencyConversionController.java
@@ -4,6 +4,8 @@
 import java.util.HashMap;
 import java.util.Map;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -14,6 +16,8 @@
 @RestController
 public class CurrencyConversionController {
 
+ private Logger logger = LoggerFactory.getLogger(this.getClass());
+
  @Autowired
  private CurrencyExchangeServiceProxy proxy;
 
@@ -42,6 +46,8 @@ public CurrencyConversionBean convertCurrencyFeign(@PathVariable String from, @P
 
  CurrencyConversionBean response = proxy.retrieveExchangeValue(from, to);
 
+ logger.info("{}", response);
+
  return new CurrencyConversionBean(response.getId(), from, to, response.getConversionMultiple(), quantity,
  quantity.multiply(response.getConversionMultiple()), response.getPort());
  }

diff --git a/...minutes/microservices/currencyconversionservice/CurrencyConversionServiceApplication.java b/...minutes/microservices/currencyconversionservice/CurrencyConversionServiceApplication.java
@@ -4,6 +4,8 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.cloud.netflix.feign.EnableFeignClients;
+import org.springframework.cloud.sleuth.sampler.AlwaysSampler;
+import org.springframework.context.annotation.Bean;
 
 @SpringBootApplication
 @EnableFeignClients("com.in28minutes.microservices.currencyconversionservice")
@@ -13,4 +15,10 @@ public class CurrencyConversionServiceApplication {
  public static void main(String[] args) {
  SpringApplication.run(CurrencyConversionServiceApplication.class, args);
  }
+
+ @Bean
+ public AlwaysSampler defaultSampler() {
+ return new AlwaysSampler();
+ }
+
 }
diff --git a/...com/in28minutes/microservices/currencyconversionservice/CurrencyExchangeServiceProxy.java b/...com/in28minutes/microservices/currencyconversionservice/CurrencyExchangeServiceProxy.java
@@ -6,10 +6,12 @@
 import org.springframework.web.bind.annotation.PathVariable;
 
 //@FeignClient(name="currency-exchange-service", url="localhost:8000")
-@FeignClient(name="currency-exchange-service")
+//@FeignClient(name="currency-exchange-service")
+@FeignClient(name="netflix-zuul-api-gateway-server")
 @RibbonClient(name="currency-exchange-service")
 public interface CurrencyExchangeServiceProxy {
- @GetMapping("/currency-exchange/from/{from}/to/{to}")
+ //@GetMapping("/currency-exchange/from/{from}/to/{to}")
+ @GetMapping("/currency-exchange-service/currency-exchange/from/{from}/to/{to}")
  public CurrencyConversionBean retrieveExchangeValue
  (@PathVariable("from") String from, @PathVariable("to") String to);
 }
diff --git a/03.microservices/currency-exchange-service/pom.xml b/03.microservices/currency-exchange-service/pom.xml
@@ -26,10 +26,6 @@
  </properties>
 
  <dependencies>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-actuator</artifactId>
- </dependency>
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-config</artifactId>
@@ -38,6 +34,10 @@
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-eureka</artifactId>
  </dependency>
+ <dependency>
+ <groupId>org.springframework.cloud</groupId>
+ <artifactId>spring-cloud-starter-sleuth</artifactId>
+ </dependency>
 
  <dependency>
  <groupId>org.springframework.boot</groupId>
@@ -53,11 +53,6 @@
  </dependency>
 
 
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-devtools</artifactId>
- <scope>runtime</scope>
- </dependency>
  <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>

diff --git a/...ava/com/in28minutes/microservices/currencyexchangeservice/CurrencyExchangeController.java b/...ava/com/in28minutes/microservices/currencyexchangeservice/CurrencyExchangeController.java
@@ -1,5 +1,7 @@
 package com.in28minutes.microservices.currencyexchangeservice;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.core.env.Environment;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -9,6 +11,8 @@
 @RestController
 public class CurrencyExchangeController {
 
+ private Logger logger = LoggerFactory.getLogger(this.getClass());
+
  @Autowired
  private Environment environment;
 
@@ -25,6 +29,8 @@ public class CurrencyExchangeController {
  exchangeValue.setPort(
  Integer.parseInt(environment.getProperty("local.server.port")));
 
+ logger.info("{}", exchangeValue);
+
  return exchangeValue;
  }
 }
diff --git a/...in28minutes/microservices/currencyexchangeservice/CurrencyExchangeServiceApplication.java b/...in28minutes/microservices/currencyexchangeservice/CurrencyExchangeServiceApplication.java
@@ -3,6 +3,8 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.sleuth.sampler.AlwaysSampler;
+import org.springframework.context.annotation.Bean;
 
 @SpringBootApplication
 @EnableDiscoveryClient
@@ -11,4 +13,10 @@ public class CurrencyExchangeServiceApplication {
  public static void main(String[] args) {
  SpringApplication.run(CurrencyExchangeServiceApplication.class, args);
  }
+
+ @Bean
+ public AlwaysSampler defaultSampler(){
+ return new AlwaysSampler();
+ }
+
 }
diff --git a/03.microservices/limits-service/pom.xml b/03.microservices/limits-service/pom.xml
@@ -26,10 +26,6 @@
  </properties>
 
  <dependencies>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-actuator</artifactId>
- </dependency>
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-config</artifactId>
@@ -39,11 +35,6 @@
  <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
 
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-devtools</artifactId>
- <scope>runtime</scope>
- </dependency>
  <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>

diff --git a/03.microservices/netflix-eureka-naming-server/pom.xml b/03.microservices/netflix-eureka-naming-server/pom.xml
@@ -26,10 +26,6 @@
  </properties>
 
  <dependencies>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-actuator</artifactId>
- </dependency>
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-config</artifactId>
@@ -38,12 +34,6 @@
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-eureka-server</artifactId>
  </dependency>
-
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-devtools</artifactId>
- <scope>runtime</scope>
- </dependency>
  <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>

diff --git a/03.microservices/netflix-zuul-api-gateway-server/pom.xml b/03.microservices/netflix-zuul-api-gateway-server/pom.xml
@@ -26,24 +26,21 @@
  </properties>
 
  <dependencies>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-actuator</artifactId>
- </dependency>
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-eureka</artifactId>
  </dependency>
+
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-zuul</artifactId>
  </dependency>
 
  <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-devtools</artifactId>
- <scope>runtime</scope>
+ <groupId>org.springframework.cloud</groupId>
+ <artifactId>spring-cloud-starter-sleuth</artifactId>
  </dependency>
+
  <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>

diff --git a/...tes/microservices/netflixzuulapigatewayserver/NetflixZuulApiGatewayServerApplication.java b/...tes/microservices/netflixzuulapigatewayserver/NetflixZuulApiGatewayServerApplication.java
@@ -4,6 +4,8 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
+import org.springframework.cloud.sleuth.sampler.AlwaysSampler;
+import org.springframework.context.annotation.Bean;
 
 @EnableZuulProxy
 @EnableDiscoveryClient
@@ -13,4 +15,9 @@ public class NetflixZuulApiGatewayServerApplication {
  public static void main(String[] args) {
  SpringApplication.run(NetflixZuulApiGatewayServerApplication.class, args);
  }
+
+ @Bean
+ public AlwaysSampler defaultSampler(){
+ return new AlwaysSampler();
+ }
 }
diff --git a/03.microservices/notes.md b/03.microservices/notes.md
@@ -8,10 +8,7 @@
 | Currency Converter Service - Feign| http://localhost:8100/currency-converter-feign/from/EUR/to/INR/quantity/10000|
 | Currency Exchange Service | http://localhost:8000/currency-exchange/from/EUR/to/INR http://localhost:8001/currency-exchange/from/USD/to/INR|
 | Eureka | http://localhost:8761/|
-| Zuul - Currency Exchange Service | http://localhost:8765/currency-exchange-service/currency-exchange/from/EUR/to/INR|
-
-- 
-- 
+| Zuul - Currency Exchange & Exchange Services | http://localhost:8765/currency-exchange-service/currency-exchange/from/EUR/to/INR http://localhost:8765/currency-conversion-service/currency-converter-feign/from/USD/to/INR/quantity/10|
 
 ## VM Argument
 

diff --git a/03.microservices/spring-cloud-config-server/pom.xml b/03.microservices/spring-cloud-config-server/pom.xml
@@ -31,11 +31,6 @@
  <artifactId>spring-cloud-config-server</artifactId>
  </dependency>
 
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-devtools</artifactId>
- <scope>runtime</scope>
- </dependency>
  <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>

diff --git a/README.md b/README.md
@@ -58,6 +58,18 @@ Refer each steps
 - Git Client - https://git-scm.com/
 - Rabbit MQ - https://www.rabbitmq.com/download.html
 
+## Installing Rabbit MQ
+
+### Windows
+- https://www.rabbitmq.com/install-windows.html
+- https://www.rabbitmq.com/which-erlang.html
+- http://www.erlang.org/downloads
+- Video - https://www.youtube.com/watch?v=gKzKUmtOwR4
+
+### Mac
+- https://www.rabbitmq.com/install-homebrew.html
+
+
 ### Basic Tools
 - Installation Video : https://www.youtube.com/playlist?list=PLBBog2r6uMCSmMVTW_QmDLyASBvovyAO3
 - GIT Repository For Installation : https://github.com/in28minutes/getting-started-in-5-steps