docs: update poison pill

This commit is contained in:
Ilkka Seppälä committed 2024-05-16 14:25:37 +03:00
1 parent f485c3d603
commit 5e8e566a34
4 files changed
+66 -52

No files matched your search

@@ -92,7 +92,7 @@ class ConsumerTest {
return msg;
}
private class InMemoryAppender extends AppenderBase<ILoggingEvent> {
private static class InMemoryAppender extends AppenderBase<ILoggingEvent> {
private final List<ILoggingEvent> log = new LinkedList<>();
public InMemoryAppender(Class clazz) {
@@ -39,16 +39,12 @@ class PoisonMessageTest {
@Test
void testAddHeader() {
assertThrows(UnsupportedOperationException.class, () -> {
POISON_PILL.addHeader(Headers.SENDER, "sender");
});
assertThrows(UnsupportedOperationException.class, () -> POISON_PILL.addHeader(Headers.SENDER, "sender"));
}
@Test
void testGetHeader() {
assertThrows(UnsupportedOperationException.class, () -> {
POISON_PILL.getHeader(Headers.SENDER);
});
assertThrows(UnsupportedOperationException.class, () -> POISON_PILL.getHeader(Headers.SENDER));
}
@Test
@@ -58,9 +54,7 @@ class PoisonMessageTest {
@Test
void testSetBody() {
assertThrows(UnsupportedOperationException.class, () -> {
POISON_PILL.setBody("Test message.");
});
assertThrows(UnsupportedOperationException.class, () -> POISON_PILL.setBody("Test message."));
}
@Test
@@ -56,10 +56,6 @@ class SimpleMessageTest {
void testUnModifiableHeaders() {
final var message = new SimpleMessage();
final var headers = message.getHeaders();
assertThrows(UnsupportedOperationException.class, () -> {
headers.put(Message.Headers.SENDER, "test");
});
assertThrows(UnsupportedOperationException.class, () -> headers.put(Message.Headers.SENDER, "test"));
}
}