GitHub/Spring
1
0
Fork 0
mirror of https://github.com/OtusTeam/Spring.git synced 2026-05-30 10:50:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

2022-11 spring-42-rabbit updated

Browse Source
This commit is contained in:
stvort
2023-05-12 20:50:43 +04:00
parent 8e86be35a2
commit 1138bb4a8a
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
2022-11/spring-42-rabbit/user-activity-processor-microservice/src/main/java/ru/otus/example/rabbitmq/rabbitmq/RabbitMqListener.java
+4 -7
View File
@@ -28,14 +28,12 @@ public class RabbitMqListener {
private final ActivityStatRepository activityStatRepository;
private final UserActivityToEmailTransformer messageTransformer;
private final JavaMailSender mailSender;
private final ObjectMapper objectMapper;
@RabbitListener(queues = "important-activity-queue")
public void processImportantMessages(UserActivity message) throws JsonProcessingException {
public void processImportantMessages(UserActivity message) {
System.out.println("RECEIVED FROM important-activity-queue: " + message);
try {
//val userActivity = objectMapper.readValue(message, UserActivity.class);
System.out.println("RECEIVED FROM important-activity-queue: " + message);
val mailMessage = messageTransformer.transform(message);
System.out.println("Как будто посылаем письмо: " + mailMessage);
//mailSender.send(mailMessage);
@@ -45,10 +43,9 @@ public class RabbitMqListener {
}
@RabbitListener(queues = "all-activity-queue")
public void processAllMessages(UserActivity message) throws JsonProcessingException {
public void processAllMessages(UserActivity message) {
System.out.println("RECEIVED FROM all-activity-queue: " + message);
try {
//val userActivity = objectMapper.readValue(message, UserActivity.class);
System.out.println("RECEIVED FROM all-activity-queue: " + message);
activityRepository.save(message);
} catch (Exception e) {
throw new AmqpRejectAndDontRequeueException("Ooops");