udpExceptionCaught() — netty Function Reference

Source Code

handler/src/test/java/io/netty/handler/pcap/PcapWriteHandlerTest.java lines 425–458

    @Test
    public void udpExceptionCaught() {
        final ByteBuf pcapBuffer = Unpooled.buffer();
        try {
            final RuntimeException exception = new RuntimeException();

            InetSocketAddress serverAddr = new InetSocketAddress("1.1.1.1", 1234);
            InetSocketAddress clientAddr = new InetSocketAddress("2.2.2.2", 3456);

            CloseDetectingByteBufOutputStream outputStream = new CloseDetectingByteBufOutputStream(pcapBuffer);
            // We fake a client
            EmbeddedChannel embeddedChannel = new EmbeddedDatagramChannel(clientAddr, serverAddr);
            embeddedChannel.pipeline().addLast(PcapWriteHandler.builder()
                    .build(outputStream));
            embeddedChannel.pipeline().fireExceptionCaught(exception);

            assertTrue(outputStream.closeCalled());

            // Verify only the PCAP global header was written.
            assertEquals(24, pcapBuffer.readableBytes());

            // Verify thrown exception
            try {
                embeddedChannel.checkException();
                fail();
            } catch (Throwable t) {
                assertSame(exception, t);
            }

            assertFalse(embeddedChannel.finishAndReleaseAll());
        } finally {
            pcapBuffer.release();
        }
    }