chathurangat

version: '3'

services:
  mysql-docker-container:
    image: mysql:latest
    environment:
      - MYSQL_ROOT_PASSWORD=root123
      - MYSQL_DATABASE=spring_app_db
      - MYSQL_USER=app_user
      - MYSQL_PASSWORD=test123

chathurangat

public interface AmazonS3ClientService
{
    void uploadFileToS3Bucket(MultipartFile multipartFile, boolean enablePublicReadAccess);

    void deleteFileFromS3Bucket(String fileName);
}

chathurangat

import com.amazonaws.services.s3.model.CannedAccessControlList;
import com.amazonaws.services.s3.model.DeleteObjectRequest;
import com.amazonaws.services.s3.model.PutObjectRequest;
import com.springbootdev.amazon.s3.example.aws.service.AmazonS3ClientService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

chathurangat

import com.springbootdev.amazon.s3.example.aws.service.AmazonS3ClientService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.util.HashMap;
import java.util.Map;

@RestController
@RequestMapping("/files")

chathurangat

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.regions.Region;
import com.amazonaws.regions.Regions;

chathurangat

@Slf4j
@EnableBinding(OrderSink.class)
public class OrderListener
{
    @StreamListener(target = OrderSink.INPUT,condition = "headers['payment_mode']=='cash'")
    public void listenForCashOrder(Order order)
    {
      log.info(" received new CASH order {} ",order.toString());
    }

chathurangat

@Slf4j
@EnableBinding(OrderSource.class)
@RestController
public class OrderController
{
    @Autowired
    private OrderSource source;

    @PostMapping("/orders/publish")
    public String publishOrder(@RequestBody Order order, @RequestParam("payment_mode") String paymentMode)

chathurangat

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@Slf4j
@EnableBinding(OrderSink.class)
public class OrderListener
{
    @StreamListener(target = OrderSink.INPUT)
    public void listenForOrder(Order order)

chathurangat

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface OrderSink
{
    String INPUT = "orderReceiveChannel";

    @Input(INPUT)
    SubscribableChannel receive();
}

chathurangat

@Slf4j
@EnableBinding(OrderSource.class)
@RestController
public class OrderController
{
    @Autowired
    private OrderSource source;

    @PostMapping("/orders/publish")
    public String publishOrder(@RequestBody Order order)