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-producer</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>order-producer</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_producer/OrderProducerApplication.java

+package com.nisum.order_producer;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class OrderProducerApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(OrderProducerApplication.class, args);
+	}
+
+}

src/main/java/com/nisum/order_producer/advice/OrderProducerExceptionHandler.java

+package com.nisum.order_producer.advice;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.FieldError;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.springframework.web.bind.support.WebExchangeBindException;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@RestControllerAdvice
+public class OrderProducerExceptionHandler {
+
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    public ResponseEntity<Map<String, String>> handleArgumentValidationException(MethodArgumentNotValidException ex){
+        Map<String,String> errors = new HashMap<>();
+        ex.getBindingResult().getFieldErrors().forEach(error->
+                errors.put(error.getField(), error.getDefaultMessage())
+        );
+        //return ResponseEntity.badRequest().body(errors);
+        return new ResponseEntity<>(errors, HttpStatus.BAD_REQUEST);
+
+    }
+
+    @ExceptionHandler(WebExchangeBindException.class)
+    public ResponseEntity<Map<String, String>> handleFieldValidationException(WebExchangeBindException ex){
+        Map<String,String> errors = new HashMap<>();
+        ex.getBindingResult().getFieldErrors().forEach(error->
+                errors.put(error.getField(), error.getDefaultMessage())
+        );
+        //return ResponseEntity.badRequest().body(errors);
+        return new ResponseEntity<>(errors, HttpStatus.BAD_REQUEST);
+
+    }
+}

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

+package com.nisum.order_producer.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("${consumer.base-url}")
+    private String baseUrl;
+
+    @Bean
+    public WebClient getWebClient(){
+        return WebClient
+                .builder()
+                .baseUrl(baseUrl)
+                .build();
+    }
+
+
+}

src/main/java/com/nisum/order_producer/controller/OrderProducerController.java

+package com.nisum.order_producer.controller;
+
+import com.nisum.order_producer.dto.OrderDto;
+import com.nisum.order_producer.entity.Order;
+import com.nisum.order_producer.service.OrderProducerService;
+import jakarta.validation.Valid;
+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("/orderProducer")
+public class OrderProducerController {
+
+    @Autowired
+    private OrderProducerService orderProducerService;
+
+    private static final Logger logger = LoggerFactory.getLogger(OrderProducerController.class);
+
+    @PostMapping("/addOrder")
+    public Mono<ResponseEntity<Order>> addOrder(@Valid @RequestBody Mono<Order> orderInfo) {
+
+
+        logger.info("Received request to add a new order : ");
+        return orderInfo
+                .flatMap(order -> {
+                    logger.info("Processing order: {}", orderInfo);
+                    return orderProducerService.saveOrder(order);
+                })
+                .map(savedOrder -> {
+                    logger.info("Successfully saved order: {}");
+                    return ResponseEntity.ok(savedOrder);
+                })
+                .doOnError(error -> logger.error("Error while saving order:"))
+                .defaultIfEmpty(ResponseEntity.badRequest().build());
+
+
+    }
+
+    /*public Mono<ResponseEntity<OrderDto>> addProduct(@Valid @RequestBody Mono<OrderDto> orderMono) {
+        logger.info("Received request to add a new order");
+
+        return orderMono
+                .flatMap(order -> {
+                    logger.info("Processing order: {}", order);
+                    return orderProducerService.saveOrder(order);
+                })
+                .map(savedOrder -> {
+                    logger.info("Successfully saved order: {}", savedOrder);
+                    return ResponseEntity.ok(savedOrder);
+                })
+                .doOnError(error -> logger.error("Error while saving order: {}", error.getMessage()));
+
+    }*/
+
+
+    @GetMapping("/findAllOrders")
+    public ResponseEntity<Flux<Order>> findAllOrders(){
+        logger.info("Received request to fetch all orders");
+        Flux<Order> orders = orderProducerService.getAllOrder();
+        return ResponseEntity.ok(orders);
+    }
+
+    @GetMapping("/findOrderById/{id}")
+    public Mono<ResponseEntity<Order>> findOrderById(@PathVariable String id){
+        logger.info("Fetching order with ID: {}", id);
+        return orderProducerService.getByOrderId(id)
+                .map(orderDto -> {
+                    logger.info("Order found: {}", orderDto);
+                    return ResponseEntity.ok(orderDto);
+                })
+                .doOnError(error -> logger.error("Error fetching order: {}", error.getMessage()))
+                .defaultIfEmpty(ResponseEntity.notFound().build());
+    }
+
+
+}

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

+package com.nisum.order_producer.dto;
+
+import jakarta.validation.constraints.Min;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+
+public class ItemDto {
+
+
+    @NotNull(message = "Item id cannot be null")
+    private String itemId;
+
+    @NotEmpty(message = "Item name cannot be empty")
+    private String itemName;
+
+    @Min(value = 1, message = "Quantity must be at least 1")
+    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_producer/dto/OrderDto.java

+package com.nisum.order_producer.dto;
+
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import java.util.List;
+
+
+public class OrderDto {
+
+    @NotNull
+    private String orderId;
+
+    private String customerId;
+    private List<ItemDto> items;
+    private String createdBy;
+    private String modifiedBy;
+
+   }

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

+package com.nisum.order_producer.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+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;
+    }
+
+    @Override
+    public String toString() {
+        return "Item{" +
+                "itemId='" + itemId + '\'' +
+                ", itemName='" + itemName + '\'' +
+                ", quantity=" + quantity +
+                '}';
+    }
+}

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

+package com.nisum.order_producer.entity;
+
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+import lombok.*;
+import org.springframework.data.mongodb.core.mapping.Document;
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Document(collection = "order_producer")
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+@Setter
+@Getter
+public class Order {
+
+
+    private String orderId;
+    @NotNull(message = "Customer ID cannot be null")
+    @NotEmpty(message = "Customer ID cannot be empty")
+    private String customerId;
+    @NotNull(message = "Items cannot be null")
+    @Size(min = 1, message = "Order must contain at least one item")
+    private List<Item> items;
+    private LocalDateTime createdDate;
+    private LocalDateTime modifiedDate;
+
+    @NotNull(message = "Modified by cannot be null")
+    @NotEmpty(message = "Modified by cannot be empty")
+    private String modifiedBy;
+    @NotNull(message = "Created by cannot be null")
+    @NotEmpty(message = "Created by cannot be empty")
+    private String createdBy;
+
+    @Override
+    public String toString() {
+        return "Order{" +
+                "orderId='" + orderId + '\'' +
+                ", customerId='" + customerId + '\'' +
+                ", items=" + items +
+                ", createdDate=" + createdDate +
+                ", modifiedDate=" + modifiedDate +
+                ", modifiedBy='" + modifiedBy + '\'' +
+                ", createdBy='" + createdBy + '\'' +
+                '}';
+    }
+}

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

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

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

+package com.nisum.order_producer.mapper;
+
+import com.nisum.order_producer.dto.OrderDto;
+import com.nisum.order_producer.entity.Order;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+@Mapper(componentModel = "spring",uses =  {ItemMapper.class}) // Enables Spring Dependency Injection
+public interface OrderMapper {
+
+   // OrderMapper INSTANCE = Mappers.getMapper(OrderMapper.class);
+
+    Order toEntity(OrderDto orderDto);
+    OrderDto toDto(Order order);
+}

src/main/java/com/nisum/order_producer/repository/OrderProducerRepository.java

+package com.nisum.order_producer.repository;
+
+import com.nisum.order_producer.entity.Order;
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+
+public interface OrderProducerRepository extends ReactiveMongoRepository<Order, String> {
+
+
+}

src/main/java/com/nisum/order_producer/service/OrderProducerService.java

+package com.nisum.order_producer.service;
+
+import com.nisum.order_producer.dto.OrderDto;
+import com.nisum.order_producer.entity.Order;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+public interface OrderProducerService {
+
+    public Mono<Order> saveOrder(Order order);
+
+    public Flux<Order> getAllOrder();
+
+    public Mono<Order> getByOrderId(String id);
+}

src/main/java/com/nisum/order_producer/service/OrderProducerServiceImpl.java

+package com.nisum.order_producer.service;
+
+import com.nisum.order_producer.dto.OrderDto;
+import com.nisum.order_producer.entity.Order;
+import com.nisum.order_producer.mapper.OrderMapper;
+import com.nisum.order_producer.repository.OrderProducerRepository;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+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;
+
+@Service
+public class OrderProducerServiceImpl implements OrderProducerService {
+    @Value("${consumer.base-url}")
+    private String baseUrl;
+
+    @Autowired
+    private OrderProducerRepository orderProducerRepository;
+
+    @Autowired
+    private WebClient webClient;
+
+    @Autowired
+    private OrderMapper orderMapper;
+    private static final Logger logger = LoggerFactory.getLogger(OrderProducerServiceImpl.class);
+
+
+
+    @Override
+    public Mono<Order> saveOrder(Order order) {
+
+        logger.info("Received request to save order: {}", order);
+
+        //Order order = orderMapper.toEntity(orderDto);
+        order.setCreatedDate(LocalDateTime.now());
+        order.setModifiedDate(LocalDateTime.now());
+
+       // logger.info("Mapped Order DTO to Entity: {}", order);
+
+        return orderProducerRepository
+                .save(order)
+                .doOnSuccess(savedOrder -> logger.info("Order saved successfully: {}", savedOrder))
+                .flatMap(savedOrder -> sendOrderToConsumer(savedOrder)
+                        .thenReturn(savedOrder))
+                .doOnError(error -> logger.error("Error saving order: {}", error.getMessage()));
+    }
+
+    @Override
+    public Flux<Order> getAllOrder() {
+        logger.info("Fetching all orders...");
+        return orderProducerRepository
+                .findAll()
+                .doOnComplete(() -> logger.info("Fetched all orders successfully"))
+                .doOnError(error -> logger.error("Error fetching orders: {}", error.getMessage()));
+    }
+
+    @Override
+    public Mono<Order> getByOrderId(String id) {
+        logger.info("Fetching order with ID: {}", id);
+        return orderProducerRepository
+                .findById(id)
+                .doOnSuccess(orderDto -> logger.info("Order found: {}", orderDto))
+                .switchIfEmpty(Mono.error(new RuntimeException("Order not found with id " + id)))
+                .doOnError(error -> logger.error("Error fetching order by ID {}: {}", id, error.getMessage()));
+    }
+
+    private Mono<Void> sendOrderToConsumer(Order order){
+        logger.info("Sending order to consumer: {}", order);
+        return webClient
+                .post()
+                .uri(baseUrl + "/saveOrder")
+                .bodyValue(order)
+                .retrieve()
+                .bodyToMono(Void.class)
+                .doOnSuccess(response -> logger.info("Successfully sent order to consumer"))
+                .onErrorResume(ex -> {
+                    logger.error("Error sending data to consumer: {}", ex.getMessage());
+                    return Mono.empty();
+                });
+    }
+}

src/main/resources/application.properties

+spring.application.name=order-producer

src/main/resources/application.yml

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

src/test/java/com/nisum/order_producer/OrderProducerApplicationTests.java

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