Skip to content

Commit dc00eac

Browse files
fix: calling status controller and removing sqs template
1 parent cfa9c8e commit dc00eac

File tree

4 files changed

+5
-19
lines changed

4 files changed

+5
-19
lines changed

src/main/java/br/com/grupo63/serviceproduction/api/controller/status/StatusAPIController.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66
import br.com.grupo63.techchallenge.common.api.controller.AbstractAPIController;
77
import br.com.grupo63.techchallenge.common.exception.NotFoundException;
88
import br.com.grupo63.techchallenge.common.exception.ValidationException;
9-
import io.awspring.cloud.sqs.operations.SqsTemplate;
109
import io.swagger.v3.oas.annotations.Operation;
1110
import io.swagger.v3.oas.annotations.Parameter;
1211
import io.swagger.v3.oas.annotations.tags.Tag;
@@ -23,15 +22,6 @@
2322
public class StatusAPIController extends AbstractAPIController {
2423

2524
private final StatusController controller;
26-
private final SqsTemplate sqsTemplate;
27-
28-
@GetMapping("/batata")
29-
public void batata() {
30-
sqsTemplate.send(sqsSendOptions ->
31-
sqsSendOptions
32-
.queue("approvedPayments.fifo")
33-
.payload(12));
34-
}
3525

3626
@Operation(
3727
tags = "5ª chamada - Fluxo principal - Acompanhamento e entrega",

src/main/java/br/com/grupo63/serviceproduction/api/controller/status/StatusQueueController.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
package br.com.grupo63.serviceproduction.api.controller.status;
22

33
import br.com.grupo63.serviceproduction.controller.StatusController;
4+
import br.com.grupo63.techchallenge.common.exception.NotFoundException;
5+
import br.com.grupo63.techchallenge.common.exception.ValidationException;
46
import com.amazonaws.services.sqs.model.Message;
57
import io.awspring.cloud.sqs.annotation.SqsListener;
68
import lombok.RequiredArgsConstructor;
@@ -15,7 +17,7 @@ public class StatusQueueController {
1517
private final StatusController controller;
1618

1719
@SqsListener(value = "approvedPayments.fifo")
18-
public void processMessage(int message) {
19-
System.err.println(message);
20+
public void processMessage(int orderId) throws ValidationException, NotFoundException {
21+
controller.advanceStatus(orderId);
2022
}
2123
}

src/main/java/br/com/grupo63/serviceproduction/config/SQSClientConfig.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package br.com.grupo63.serviceproduction.config;
22

3-
import io.awspring.cloud.sqs.operations.SqsTemplate;
43
import org.springframework.beans.factory.annotation.Value;
54
import org.springframework.context.annotation.Bean;
65
import org.springframework.context.annotation.Configuration;
@@ -30,9 +29,4 @@ SqsAsyncClient sqsAsyncClient(){
3029
.create(AwsBasicCredentials.create(accessKey, secretKey)))
3130
.build();
3231
}
33-
34-
@Bean
35-
public SqsTemplate sqsTemplate(SqsAsyncClient sqsAsyncClient){
36-
return SqsTemplate.builder().sqsAsyncClient(sqsAsyncClient).build();
37-
}
3832
}

src/test/java/br/com/grupo63/serviceproduction/ProductionIntegrationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public void setUp() {
4545
MockitoAnnotations.openMocks(this);
4646
statusUseCase = new StatusUseCase(statusJpaAdapter);
4747
statusController = new StatusController(statusUseCase);
48-
statusAPIController = new StatusAPIController(statusController, null);
48+
statusAPIController = new StatusAPIController(statusController);
4949
}
5050

5151
@SneakyThrows

0 commit comments

Comments
 (0)