docs: update publish-subscribe

This commit is contained in:
Ilkka Seppälä
2025-04-15 20:36:32 +03:00
parent 1a08b73af8
commit 9f7ce4e732
7 changed files with 114 additions and 141 deletions
@@ -28,7 +28,7 @@ import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
import org.junit.jupiter.api.Test;
public class AppTest {
class AppTest {
@Test
void shouldExecuteApplicationWithoutException() {
@@ -28,7 +28,6 @@ import ch.qos.logback.classic.Logger;
import ch.qos.logback.classic.spi.ILoggingEvent;
import ch.qos.logback.core.read.ListAppender;
import java.util.List;
import java.util.stream.Collectors;
import org.junit.jupiter.api.extension.AfterEachCallback;
import org.junit.jupiter.api.extension.BeforeEachCallback;
import org.junit.jupiter.api.extension.ExtensionContext;
@@ -53,12 +52,10 @@ public class LoggerExtension implements BeforeEachCallback, AfterEachCallback {
}
public List<String> getMessages() {
return listAppender.list.stream().map(e -> e.getMessage()).collect(Collectors.toList());
return listAppender.list.stream().map(e -> e.getMessage()).toList();
}
public List<String> getFormattedMessages() {
return listAppender.list.stream()
.map(e -> e.getFormattedMessage())
.collect(Collectors.toList());
return listAppender.list.stream().map(e -> e.getFormattedMessage()).toList();
}
}
@@ -29,10 +29,10 @@ import static org.junit.jupiter.api.Assertions.assertInstanceOf;
import org.junit.jupiter.api.Test;
public class MessageTest {
class MessageTest {
@Test
public void testMessage() {
void testMessage() {
final String content = "some content";
Message message = new Message(content);
assertInstanceOf(String.class, message.content());
@@ -33,7 +33,7 @@ import java.lang.reflect.Field;
import java.util.Set;
import org.junit.jupiter.api.Test;
public class TopicTest {
class TopicTest {
private static final String TOPIC_WEATHER = "WEATHER";
@@ -36,7 +36,7 @@ import java.util.Set;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension;
public class PublisherTest {
class PublisherTest {
@RegisterExtension public LoggerExtension loggerExtension = new LoggerExtension();