dockerization of rabbitmq

Author: mehmetozkaya

docker-compose.override.yml

@@ -16,6 +16,13 @@ services:
         ports:
             - "6379:6379"
 
+    rabbitmq:
+        container_name: rabbitmq
+        restart: always
+        ports:
+            - "5672:5672"
+            - "15672:15672"
+
     catalog.api:
         container_name: catalogapi
         environment:
@@ -34,8 +41,10 @@ services:
         environment:
             - ASPNETCORE_ENVIRONMENT=Development
             - "ConnectionStrings:Redis=basketdb:6379"
+            - "EventBus:HostName=rabbitmq"
         depends_on:
             - basketdb
+            - rabbitmq
         volumes:
             - ${HOME}/.microsoft/usersecrets/:/root/.microsoft/usersecrets
             - ${HOME}/.aspnet/https:/root/.aspnet/https/

docker-compose.yml

@@ -7,6 +7,9 @@ services:
     basketdb:
         image: redis
 
+    rabbitmq:
+        image: rabbitmq:3-management-alpine
+
     catalog.api:
         image: ${DOCKER_REGISTRY-}catalogapi
         build:

src/Basket/Basket.API/Controllers/BasketController.cs

@@ -59,14 +59,19 @@ public async Task<ActionResult> Checkout([FromBody] BasketCheckout basketCheckou
         {
             // get total price of the basket
             // remove the basket 
-            // send checkout event to rabbitMq            
+            // send checkout event to rabbitMq 
 
             var basket = await _repository.GetBasket(basketCheckout.UserName);
-            var totalPrice = basket.TotalPrice;
+            if (basket == null)
+            {
+                _logger.LogError("Basket not exist with this user : {EventId}", basketCheckout.UserName);
+                return BadRequest();
+            }
 
             var basketRemoved = await _repository.DeleteBasket(basketCheckout.UserName);
             if (!basketRemoved)
             {
+                _logger.LogError("Basket can not deleted");
                 return BadRequest();
             }
 
@@ -76,7 +81,7 @@ public async Task<ActionResult> Checkout([FromBody] BasketCheckout basketCheckou
 
             var eventMessage = _mapper.Map<BasketCheckoutEvent>(basketCheckout);
             eventMessage.RequestId = Guid.NewGuid();
-            eventMessage.TotalPrice = totalPrice;
+            eventMessage.TotalPrice = basket.TotalPrice;
 
             try
             {