henriquesousazup

package com.zcoders.restaurante.listener;

import com.zcoders.restaurante.model.Item;
import com.zcoders.restaurante.model.Pedido;
import com.zcoders.restaurante.model.StatusPedido;
import com.zcoders.restaurante.repository.ItemRepository;
import com.zcoders.restaurante.repository.PedidoRepository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;

henriquesousazup

package com.zupfood.pedidos.pedido;

import com.zupfood.pedidos.item.Item;
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.kafka.core.KafkaTemplate;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

henriquesousazup

package com.zcoders.notificacao.listener;

import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.kafka.common.errors.SerializationException;
import org.apache.kafka.common.serialization.Deserializer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;

henriquesousazup

package com.zupedu.credito.listener;

import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.kafka.common.errors.SerializationException;
import org.apache.kafka.common.serialization.Deserializer;

import java.io.IOException;

public class NovaContaDeserializer implements Deserializer<NovaContaEvent> {

henriquesousazup

package br.com.zup.edu.marketplace;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;

@SpringBootApplication
@EnableAsync
public class MarketplaceApplication {

henriquesousazup

package com.zupedu.conta;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.EnableKafka;
import org.springframework.scheduling.annotation.EnableAsync;

@SpringBootApplication
@EnableAsync
public class ContaApplication {

henriquesousazup

@Component
public class ClienteNovoConsumer {

    Logger logger = LoggerFactory.getLogger(ClienteNovoConsumer.class);

    @Autowired
    private ClienteRepository clienteRepository;


    @SqsListener(value = "${cloud.aws.queue.name}", deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)

henriquesousazup

package br.com.zup.edu.ingressoagora.listener;

import br.com.zup.edu.ingressoagora.model.Cliente;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;

import java.time.LocalDate;
import java.time.LocalDateTime;

henriquesousazup

package com.zcoders.comprovante.domain;

import java.math.BigDecimal;

public class PagamentoRealizado {

    private BigDecimal valor;

    private long numeroConta;

henriquesousazup

package br.com.zup.edu.marketplace;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;

@SpringBootApplication
@EnableAsync
public class MarketplaceApplication {