Skip to content

Commit 105a184

Browse files
committed
add NettyLeakException.java
1 parent ec5c37f commit 105a184

File tree

3 files changed

+9
-2
lines changed

3 files changed

+9
-2
lines changed
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
package io.github.nettyplus.leakdetector.junit;
2+
3+
public class NettyLeakException extends RuntimeException {
4+
public NettyLeakException(String message) {
5+
super(message);
6+
}
7+
}

src/main/java/io/github/nettyplus/leakdetector/junit/NettyLeakListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ public void assertZeroLeaks(String detail) {
4949
}
5050

5151
LOGGER.error(message.toString());
52-
throw new IllegalStateException(message.toString());
52+
throw new NettyLeakException(message.toString());
5353
}
5454
}
5555

src/test/java/io/github/nettyplus/leakdetector/junit/NettyLeakDetectorExtensionTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ static void verifyAfterAll() {
4444
assertEquals("paranoid", System.getProperty( "io.netty.leakDetection.level"));
4545
int leakCount = leakListener.getLeakCount();
4646
assertTrue(leakCount > 0);
47-
IllegalStateException e = assertThrows(IllegalStateException.class, () -> leakListener.assertZeroLeaks());
47+
NettyLeakException e = assertThrows(NettyLeakException.class, () -> leakListener.assertZeroLeaks());
4848
assertTrue(e.getMessage().startsWith("Netty leaks"));
4949
assertTrue(e.getMessage().contains("resourceType=ByteBuf, records=["));
5050
}

0 commit comments

Comments
 (0)