initial commit

.gitattributes

+/mvnw text eol=lf
+*.cmd text eol=crlf

.gitignore

+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

.mvn/wrapper/maven-wrapper.properties

+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+wrapperVersion=3.3.2
+distributionType=only-script
+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.9/apache-maven-3.9.9-bin.zip

mvnw.cmd

+<# : batch portion
+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements.  See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership.  The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License.  You may obtain a copy of the License at
+@REM
+@REM    http://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied.  See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Apache Maven Wrapper startup batch script, version 3.3.2
+@REM
+@REM Optional ENV vars
+@REM   MVNW_REPOURL - repo url base for downloading maven distribution
+@REM   MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
+@REM   MVNW_VERBOSE - true: enable verbose log; others: silence the output
+@REM ----------------------------------------------------------------------------
+
+@IF "%__MVNW_ARG0_NAME__%"=="" (SET __MVNW_ARG0_NAME__=%~nx0)
+@SET __MVNW_CMD__=
+@SET __MVNW_ERROR__=
+@SET __MVNW_PSMODULEP_SAVE=%PSModulePath%
+@SET PSModulePath=
+@FOR /F "usebackq tokens=1* delims==" %%A IN (`powershell -noprofile "& {$scriptDir='%~dp0'; $script='%__MVNW_ARG0_NAME__%'; icm -ScriptBlock ([Scriptblock]::Create((Get-Content -Raw '%~f0'))) -NoNewScope}"`) DO @(
+  IF "%%A"=="MVN_CMD" (set __MVNW_CMD__=%%B) ELSE IF "%%B"=="" (echo %%A) ELSE (echo %%A=%%B)
+)
+@SET PSModulePath=%__MVNW_PSMODULEP_SAVE%
+@SET __MVNW_PSMODULEP_SAVE=
+@SET __MVNW_ARG0_NAME__=
+@SET MVNW_USERNAME=
+@SET MVNW_PASSWORD=
+@IF NOT "%__MVNW_CMD__%"=="" (%__MVNW_CMD__% %*)
+@echo Cannot start maven from wrapper >&2 && exit /b 1
+@GOTO :EOF
+: end batch / begin powershell #>
+
+$ErrorActionPreference = "Stop"
+if ($env:MVNW_VERBOSE -eq "true") {
+  $VerbosePreference = "Continue"
+}
+
+# calculate distributionUrl, requires .mvn/wrapper/maven-wrapper.properties
+$distributionUrl = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionUrl
+if (!$distributionUrl) {
+  Write-Error "cannot read distributionUrl property in $scriptDir/.mvn/wrapper/maven-wrapper.properties"
+}
+
+switch -wildcard -casesensitive ( $($distributionUrl -replace '^.*/','') ) {
+  "maven-mvnd-*" {
+    $USE_MVND = $true
+    $distributionUrl = $distributionUrl -replace '-bin\.[^.]*$',"-windows-amd64.zip"
+    $MVN_CMD = "mvnd.cmd"
+    break
+  }
+  default {
+    $USE_MVND = $false
+    $MVN_CMD = $script -replace '^mvnw','mvn'
+    break
+  }
+}
+
+# apply MVNW_REPOURL and calculate MAVEN_HOME
+# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-<version>,maven-mvnd-<version>-<platform>}/<hash>
+if ($env:MVNW_REPOURL) {
+  $MVNW_REPO_PATTERN = if ($USE_MVND) { "/org/apache/maven/" } else { "/maven/mvnd/" }
+  $distributionUrl = "$env:MVNW_REPOURL$MVNW_REPO_PATTERN$($distributionUrl -replace '^.*'+$MVNW_REPO_PATTERN,'')"
+}
+$distributionUrlName = $distributionUrl -replace '^.*/',''
+$distributionUrlNameMain = $distributionUrlName -replace '\.[^.]*$','' -replace '-bin$',''
+$MAVEN_HOME_PARENT = "$HOME/.m2/wrapper/dists/$distributionUrlNameMain"
+if ($env:MAVEN_USER_HOME) {
+  $MAVEN_HOME_PARENT = "$env:MAVEN_USER_HOME/wrapper/dists/$distributionUrlNameMain"
+}
+$MAVEN_HOME_NAME = ([System.Security.Cryptography.MD5]::Create().ComputeHash([byte[]][char[]]$distributionUrl) | ForEach-Object {$_.ToString("x2")}) -join ''
+$MAVEN_HOME = "$MAVEN_HOME_PARENT/$MAVEN_HOME_NAME"
+
+if (Test-Path -Path "$MAVEN_HOME" -PathType Container) {
+  Write-Verbose "found existing MAVEN_HOME at $MAVEN_HOME"
+  Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
+  exit $?
+}
+
+if (! $distributionUrlNameMain -or ($distributionUrlName -eq $distributionUrlNameMain)) {
+  Write-Error "distributionUrl is not valid, must end with *-bin.zip, but found $distributionUrl"
+}
+
+# prepare tmp dir
+$TMP_DOWNLOAD_DIR_HOLDER = New-TemporaryFile
+$TMP_DOWNLOAD_DIR = New-Item -Itemtype Directory -Path "$TMP_DOWNLOAD_DIR_HOLDER.dir"
+$TMP_DOWNLOAD_DIR_HOLDER.Delete() | Out-Null
+trap {
+  if ($TMP_DOWNLOAD_DIR.Exists) {
+    try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
+    catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
+  }
+}
+
+New-Item -Itemtype Directory -Path "$MAVEN_HOME_PARENT" -Force | Out-Null
+
+# Download and Install Apache Maven
+Write-Verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
+Write-Verbose "Downloading from: $distributionUrl"
+Write-Verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
+
+$webclient = New-Object System.Net.WebClient
+if ($env:MVNW_USERNAME -and $env:MVNW_PASSWORD) {
+  $webclient.Credentials = New-Object System.Net.NetworkCredential($env:MVNW_USERNAME, $env:MVNW_PASSWORD)
+}
+[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12
+$webclient.DownloadFile($distributionUrl, "$TMP_DOWNLOAD_DIR/$distributionUrlName") | Out-Null
+
+# If specified, validate the SHA-256 sum of the Maven distribution zip file
+$distributionSha256Sum = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionSha256Sum
+if ($distributionSha256Sum) {
+  if ($USE_MVND) {
+    Write-Error "Checksum validation is not supported for maven-mvnd. `nPlease disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties."
+  }
+  Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash
+  if ((Get-FileHash "$TMP_DOWNLOAD_DIR/$distributionUrlName" -Algorithm SHA256).Hash.ToLower() -ne $distributionSha256Sum) {
+    Write-Error "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised. If you updated your Maven version, you need to update the specified distributionSha256Sum property."
+  }
+}
+
+# unzip and move
+Expand-Archive "$TMP_DOWNLOAD_DIR/$distributionUrlName" -DestinationPath "$TMP_DOWNLOAD_DIR" | Out-Null
+Rename-Item -Path "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" -NewName $MAVEN_HOME_NAME | Out-Null
+try {
+  Move-Item -Path "$TMP_DOWNLOAD_DIR/$MAVEN_HOME_NAME" -Destination $MAVEN_HOME_PARENT | Out-Null
+} catch {
+  if (! (Test-Path -Path "$MAVEN_HOME" -PathType Container)) {
+    Write-Error "fail to move MAVEN_HOME"
+  }
+} finally {
+  try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
+  catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
+}
+
+Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"

pom.xml

+<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>3.4.3</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>com.nisum</groupId>
+    <artifactId>order-consumer</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>order-consumer</name>
+    <description>Demo project for Spring Boot</description>
+    <url/>
+    <licenses>
+        <license/>
+    </licenses>
+    <developers>
+        <developer/>
+    </developers>
+    <scm>
+        <connection/>
+        <developerConnection/>
+        <tag/>
+        <url/>
+    </scm>
+    <properties>
+        <java.version>17</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.mapstruct</groupId>
+            <artifactId>mapstruct</artifactId>
+            <version>1.5.5.Final</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.mapstruct</groupId>
+            <artifactId>mapstruct-processor</artifactId>
+            <version>1.5.5.Final</version>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

src/main/java/com/nisum/order_consumer/OrderConsumerApplication.java

+package com.nisum.order_consumer;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.data.mongodb.config.EnableMongoAuditing;
+
+@SpringBootApplication
+@EnableMongoAuditing
+public class OrderConsumerApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(OrderConsumerApplication.class, args);
+	}
+
+}

src/main/java/com/nisum/order_consumer/configuration/Config.java

+package com.nisum.order_consumer.configuration;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.reactive.function.client.WebClient;
+
+@Configuration
+public class Config {
+
+
+    @Value("${producer.base-url}")
+    private String baseUrl;
+
+    @Bean
+    public WebClient getWebClient(){
+        return WebClient
+                .builder()
+                .baseUrl(baseUrl)
+                .build();
+    }
+
+}

src/main/java/com/nisum/order_consumer/controller/OrderConsumerController.java

+package com.nisum.order_consumer.controller;
+
+import com.nisum.order_consumer.dto.OrderDto;
+import com.nisum.order_consumer.entity.Order;
+import com.nisum.order_consumer.service.OrderConsumerService;
+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.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping("/orderConsumer")
+public class OrderConsumerController {
+
+    @Autowired
+    private OrderConsumerService orderConsumerService;
+
+    private static final Logger logger = LoggerFactory.getLogger(OrderConsumerController.class);
+
+
+
+
+    @PostMapping("/saveOrder")
+    public Mono<ResponseEntity<Order>> saveOrder(@RequestBody Mono<Order> orderInfo) {
+        return orderInfo.doOnNext(order -> logger.info("Received OrderDto for saving: {}", order))
+                .flatMap(order -> orderConsumerService.saveOrder(order))
+                .doOnNext(savedOrder -> logger.info("Successfully saved Order: {}", savedOrder))
+                .map(ResponseEntity::ok)
+                .defaultIfEmpty(ResponseEntity.badRequest().build());
+    }
+
+    @GetMapping("/getAllOrders")
+    public Flux<Order> getAllOrders() {
+        logger.info("Fetching all orders...");
+        return orderConsumerService.getAllOrders()
+                .doOnNext(order -> logger.info("Fetched Order: {}", order));
+    }
+
+    //  Get Order By orderId
+    @GetMapping("/getByOrderId/{orderId}")
+    public Mono<ResponseEntity<Order>> getOrderById(@PathVariable String orderId) {
+        logger.info("Fetching order with ID: {}", orderId);
+        return orderConsumerService.getOrderById(orderId)
+                .doOnNext(order -> logger.info("Order found: {}", order))
+                .map(ResponseEntity::ok)
+                .defaultIfEmpty(ResponseEntity.notFound().build());
+    }
+    @GetMapping("/count/{customerId}")
+    public Mono<Long> getOrderCountByCustomerId(@PathVariable String customerId) {
+        logger.info("Fetching order count for Customer ID: {}", customerId);
+        return orderConsumerService.getOrderCountByCustomerId(customerId)
+                .doOnNext(count -> logger.info("Total orders found for Customer ID {}: {}", customerId, count));
+    }
+
+
+}
+
+

src/main/java/com/nisum/order_consumer/dto/ItemDto.java

+package com.nisum.order_consumer.dto;
+
+public class ItemDto {
+
+    private String itemId;
+    private String itemName;
+    private int quantity;
+
+    public String getItemId() {
+        return itemId;
+    }
+
+    public void setItemId(String itemId) {
+        this.itemId = itemId;
+    }
+
+    public String getItemName() {
+        return itemName;
+    }
+
+    public void setItemName(String itemName) {
+        this.itemName = itemName;
+    }
+
+    public int getQuantity() {
+        return quantity;
+    }
+
+    public void setQuantity(int quantity) {
+        this.quantity = quantity;
+    }
+}

src/main/java/com/nisum/order_consumer/dto/OrderDto.java

+package com.nisum.order_consumer.dto;
+
+import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.annotation.LastModifiedDate;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+public class OrderDto {
+
+    private String orderId;
+    private String customerId;
+    private List<ItemDto> items;
+    //@CreatedDate
+    private String createdDate;
+    //@LastModifiedDate
+    private String modifiedDate;
+    private String createdBy;
+    private String modifiedBy;
+
+    public String getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(String orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getCustomerId() {
+        return customerId;
+    }
+
+    public void setCustomerId(String customerId) {
+        this.customerId = customerId;
+    }
+
+    public List<ItemDto> getItems() {
+        return items;
+    }
+
+    public void setItems(List<ItemDto> items) {
+        this.items = items;
+    }
+
+
+    public String getCreatedDate() {
+        return createdDate;
+    }
+
+    public void setCreatedDate(String createdDate) {
+        this.createdDate = createdDate;
+    }
+
+    public String getModifiedDate() {
+        return modifiedDate;
+    }
+
+    public void setModifiedDate(String modifiedDate) {
+        this.modifiedDate = modifiedDate;
+    }
+
+    public String getCreatedBy() {
+        return createdBy;
+    }
+
+    public void setCreatedBy(String createdBy) {
+        this.createdBy = createdBy;
+    }
+
+    public String getModifiedBy() {
+        return modifiedBy;
+    }
+
+    public void setModifiedBy(String modifiedBy) {
+        this.modifiedBy = modifiedBy;
+    }
+}

src/main/java/com/nisum/order_consumer/entity/Item.java

+package com.nisum.order_consumer.entity;
+
+public class Item {
+
+    private String itemId;
+    private String itemName;
+    private int quantity;
+
+    public String getItemId() {
+        return itemId;
+    }
+
+    public void setItemId(String itemId) {
+        this.itemId = itemId;
+    }
+
+    public String getItemName() {
+        return itemName;
+    }
+
+    public void setItemName(String itemName) {
+        this.itemName = itemName;
+    }
+
+    public int getQuantity() {
+        return quantity;
+    }
+
+    public void setQuantity(int quantity) {
+        this.quantity = quantity;
+    }
+}

src/main/java/com/nisum/order_consumer/entity/Order.java

+package com.nisum.order_consumer.entity;
+
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+@Document(collection = "order_consumer")
+public class Order {
+
+    //@Id
+    private String orderId;
+    @NotNull(message = "Customer ID cannot be null")
+    @NotEmpty(message = "Customer ID cannot be empty")
+    private String customerId;
+    private List<Item> items;
+
+    //private LocalDateTime createdDate;  // Order creation timestamp
+    //private LocalDateTime modifiedDate; // Order modification timestamp
+    private LocalDateTime createdDate;
+    private LocalDateTime modifiedDate;
+    private String createdBy;
+    private String modifiedBy;
+
+    /*public String getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(String orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getCustomerId() {
+        return customerId;
+    }
+
+    public void setCustomerId(String customerId) {
+        this.customerId = customerId;
+    }
+
+    public List<Item> getItems() {
+        return items;
+    }
+
+    public void setItems(List<Item> items) {
+        this.items = items;
+    }
+
+    public String getCreatedDate() {
+        return createdDate;
+    }
+
+    public void setCreatedDate(String createdDate) {
+        this.createdDate = createdDate;
+    }
+
+    public String getModifiedDate() {
+        return modifiedDate;
+    }
+
+    public void setModifiedDate(String modifiedDate) {
+        this.modifiedDate = modifiedDate;
+    }
+
+    public String getCreatedBy() {
+        return createdBy;
+    }
+
+    public void setCreatedBy(String createdBy) {
+        this.createdBy = createdBy;
+    }
+
+    public String getModifiedBy() {
+        return modifiedBy;
+    }
+
+    public void setModifiedBy(String modifiedBy) {
+        this.modifiedBy = modifiedBy;
+    }*/
+}

src/main/java/com/nisum/order_consumer/mapper/ItemMapper.java

+package com.nisum.order_consumer.mapper;
+
+import com.nisum.order_consumer.dto.ItemDto;
+import com.nisum.order_consumer.entity.Item;
+import org.mapstruct.Mapper;
+
+@Mapper(componentModel = "spring",uses =  {ItemMapper.class})
+public interface ItemMapper {
+
+    Item toEntity(ItemDto dto);
+    ItemDto toDto(Item entity);
+
+}

src/main/java/com/nisum/order_consumer/mapper/OrderMapper.java

+package com.nisum.order_consumer.mapper;
+
+import com.nisum.order_consumer.dto.OrderDto;
+import com.nisum.order_consumer.entity.Order;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+@Mapper(componentModel = "spring")
+public interface OrderMapper {
+
+    OrderMapper INSTANCE = Mappers.getMapper(OrderMapper.class);
+
+    Order toEntity(OrderDto orderDto);
+
+    OrderDto toDto(Order order);
+
+}

src/main/java/com/nisum/order_consumer/repository/OrderConsumerRepository.java

+package com.nisum.order_consumer.repository;
+
+import com.nisum.order_consumer.entity.Order;
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import reactor.core.publisher.Mono;
+
+
+public interface OrderConsumerRepository extends ReactiveMongoRepository<Order,String>{
+    Mono<Long> countByCustomerId(String customerId);
+    Mono<Order> findByOrderId(String orderId);
+}

src/main/java/com/nisum/order_consumer/service/OrderConsumerService.java

+package com.nisum.order_consumer.service;
+
+import com.nisum.order_consumer.dto.OrderDto;
+import com.nisum.order_consumer.entity.Order;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+public interface OrderConsumerService {
+
+    Mono<Order> saveOrder(Order orderInfo);
+
+    // Retrieve all orders
+    Flux<Order> getAllOrders();
+
+    // Retrieve a specific order by orderId
+    Mono<Order> getOrderById(String orderId);
+
+    // Get order count for a specific customerId
+    Mono<Long> getOrderCountByCustomerId(String customerId);
+}

src/main/java/com/nisum/order_consumer/service/OrderConsumerServiceImpl.java

+package com.nisum.order_consumer.service;
+
+import com.nisum.order_consumer.dto.OrderDto;
+import com.nisum.order_consumer.entity.Order;
+import com.nisum.order_consumer.mapper.OrderMapper;
+import com.nisum.order_consumer.repository.OrderConsumerRepository;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Service
+public class OrderConsumerServiceImpl implements OrderConsumerService{
+
+    @Autowired
+    private OrderConsumerRepository orderConsumerRepository;
+
+    @Autowired
+    private OrderMapper orderMapper;
+
+    @Autowired
+    private WebClient webClient;
+
+    private static final Logger logger = LoggerFactory.getLogger(OrderConsumerServiceImpl.class);
+
+    @Override
+    public Mono<Order> saveOrder(Order orderInfo) {
+        logger.info("Received request to save Order: {}", orderInfo);
+
+        //Order order = orderMapper.toEntity(orderDto);
+        orderInfo.setCreatedDate(LocalDateTime.now());
+        orderInfo.setModifiedDate(LocalDateTime.now());
+
+        return orderConsumerRepository.save(orderInfo)
+                .doOnNext(savedOrder -> logger.info("Order saved successfully: {}", savedOrder));
+
+    }
+
+    @Override
+    public Flux<Order> getAllOrders() {
+        logger.info("Fetching all orders...");
+
+        return orderConsumerRepository.findAll()
+                .doOnNext(order -> logger.info("Fetched Order: {}", order));
+
+    }
+
+    @Override
+    public Mono<Order> getOrderById(String orderId) {
+        logger.info("Fetching Order with ID: {}", orderId);
+        return orderConsumerRepository.findByOrderId(orderId)
+                .doOnNext(order -> logger.info("Order found: {}", order));
+
+    }
+
+    @Override
+    public Mono<Long> getOrderCountByCustomerId(String customerId) {
+        logger.info("Fetching order count for Customer ID: {}", customerId);
+        return orderConsumerRepository.countByCustomerId(customerId)
+                .doOnNext(count -> logger.info("Total orders for Customer ID {}: {}", customerId, count));
+    }
+}

src/main/resources/application.properties

+spring.application.name=order-consumer

src/main/resources/application.yml

+server:
+  port: 8082
+
+spring:
+  application:
+    name: order-consumer
+  data:
+    mongodb:
+      host: localhost
+      port: 27017
+      database: orderdb
+
+producer:
+  base-url: "http://localhost:8081/orderProducer"
\ No newline at end of file

src/test/java/com/nisum/order_consumer/OrderConsumerApplicationTests.java

+package com.nisum.order_consumer;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class OrderConsumerApplicationTests {
+
+	@Test
+	void contextLoads() {
+	}
+
+}