Skip to content
Snippets Groups Projects
Commit 85335a2f authored by Tom Käsler's avatar Tom Käsler
Browse files

fix handler to use topic for broadcasting

parent bdcdb7a3
1 merge request!121Fix feedback messaging
Pipeline #25145 passed with warnings with stages
in 1 minute and 6 seconds
This commit is part of merge request !121. Comments created here will be created in the context of that merge request.
...@@ -39,7 +39,7 @@ public class FeedbackCommandHandler { ...@@ -39,7 +39,7 @@ public class FeedbackCommandHandler {
feedbackChanged.setPayload(feedbackChangedPayload); feedbackChanged.setPayload(feedbackChangedPayload);
messagingTemplate.convertAndSend( messagingTemplate.convertAndSend(
"/queue/" + command.getRoomId() + ".feedback.stream", "/topic/" + command.getRoomId() + ".feedback.stream",
feedbackChanged feedbackChanged
); );
} }
...@@ -53,7 +53,7 @@ public class FeedbackCommandHandler { ...@@ -53,7 +53,7 @@ public class FeedbackCommandHandler {
feedbackChanged.setPayload(feedbackChangedPayload); feedbackChanged.setPayload(feedbackChangedPayload);
messagingTemplate.convertAndSend( messagingTemplate.convertAndSend(
"/queue/" + command.getRoomId() + ".feedback.stream", "/topic/" + command.getRoomId() + ".feedback.stream",
feedbackChanged feedbackChanged
); );
} }
......
...@@ -50,7 +50,7 @@ public class FeedbackCommandHandlerTest { ...@@ -50,7 +50,7 @@ public class FeedbackCommandHandlerTest {
ArgumentCaptor.forClass(FeedbackChanged.class); ArgumentCaptor.forClass(FeedbackChanged.class);
verify(messagingTemplate).convertAndSend(topicCaptor.capture(), messageCaptor.capture()); verify(messagingTemplate).convertAndSend(topicCaptor.capture(), messageCaptor.capture());
assertThat(topicCaptor.getValue()).isEqualTo("/queue/" + roomId + ".feedback.stream"); assertThat(topicCaptor.getValue()).isEqualTo("/topic/" + roomId + ".feedback.stream");
assertThat(messageCaptor.getValue()).isEqualTo(feedbackChanged); assertThat(messageCaptor.getValue()).isEqualTo(feedbackChanged);
} }
...@@ -68,7 +68,7 @@ public class FeedbackCommandHandlerTest { ...@@ -68,7 +68,7 @@ public class FeedbackCommandHandlerTest {
ArgumentCaptor<String> captor = ArgumentCaptor.forClass(String.class); ArgumentCaptor<String> captor = ArgumentCaptor.forClass(String.class);
verify(messagingTemplate).convertAndSend(captor.capture(), any(FeedbackChanged.class)); verify(messagingTemplate).convertAndSend(captor.capture(), any(FeedbackChanged.class));
assertThat(captor.getValue()).isEqualTo("/queue/" + roomId + ".feedback.stream"); assertThat(captor.getValue()).isEqualTo("/topic/" + roomId + ".feedback.stream");
} }
} }
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment