atesibrahim

    @Test
    public void it_should_return_dispense_product_and_thank_you() {
        //Given
        Integer id = 1;
        Product product = Product.builder().id(1).name("name").price(5.0).stock(10).build();
        ProductRequest productRequest = ProductRequest.builder().id(1).build();

        //when
        when(coinAmount.getBalance()).thenReturn(10.0);
        when(productRepository.findById(id)).thenReturn(Optional.ofNullable(product));

atesibrahim

import lombok.RequiredArgsConstructor;
import org.apache.commons.lang3.StringUtils;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

atesibrahim

@RunWith(MockitoJUnitRunner.class)
public class RabbitMqConfigurationTest {

    @InjectMocks
    private RabbitMqConfiguration queueConfiguration;

    @Test
    public void it_should_get_queue() {
        //Given && //When
        final Queue queue = queueConfiguration.queue();

atesibrahim

import org.springframework.amqp.rabbit.core.RabbitTemplate;

public class EnqueueService {

    private final RabbitTemplate rabbitTemplate;

    public void enqueue(YourObject request) {
        rabbitTemplate.convertAndSend(RabbitMqExchangeConfiguration.EXCHANGE, "", request);
    }
}

atesibrahim

@RunWith(MockitoJUnitRunner.class)
public class EnqueueServiceTest {

    @InjectMocks
    private EnqueueService enqueueService;

    @Mock
    private RabbitTemplate rabbitTemplate;

    @Test

atesibrahim

import org.springframework.amqp.rabbit.annotation.RabbitListener;

public class QueueListener {

    @RabbitListener(queues = QueueConfiguration.QUEUE,
            concurrency = "1",
            errorHandler = "defaultRabbitListenerErrorHandler")
    public void listener(YourObjectDto dto) {
        //your code
    }

atesibrahim

spring:
  application:
    name: queue-api
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
    listener:
      simple:

atesibrahim

from datetime import timedelta, datetime

sys.path.append("/opt/bitnami/airflow/dags/git-d/")
from airflow.models import DAG

from Util.XSparkSubmit import spark_submit
from Util.SlackUtil import task_fail_slack_alert, task_success_slack_message

args = {
    'owner': 'Airflow',

atesibrahim

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-amqp</artifactId>
  <version>2.6.6</version>
</dependency>

atesibrahim

@Configuration
@RequiredArgsConstructor
public class RabbitMqExchangeConfiguration {

    public static final String EXCHANGE = "queue";

    private final RabbitAdmin rabbitAdmin;

    @Bean
    public TopicExchange rabbitMqExchange() {