Skip to content

Commit 0de073a

Browse files
committed
Prevent NPE
1 parent d371dd9 commit 0de073a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/ning/http/client/providers/netty/NettyAsyncHttpProvider.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2380,7 +2380,7 @@ public void setContent(ChannelBuffer content) {
23802380
public void onError(ChannelHandlerContext ctx, ExceptionEvent e) {
23812381
try {
23822382
log.warn("onError {}", e);
2383-
if (!NettyResponseFuture.class.isAssignableFrom(ctx.getAttachment().getClass())) {
2383+
if (ctx.getAttachment() == null || !NettyResponseFuture.class.isAssignableFrom(ctx.getAttachment().getClass())) {
23842384
return;
23852385
}
23862386

@@ -2398,7 +2398,7 @@ public void onError(ChannelHandlerContext ctx, ExceptionEvent e) {
23982398
//@Override
23992399
public void onClose(ChannelHandlerContext ctx, ChannelStateEvent e) {
24002400
log.trace("onClose {}", e);
2401-
if (!NettyResponseFuture.class.isAssignableFrom(ctx.getAttachment().getClass())) {
2401+
if (ctx.getAttachment() == null || !NettyResponseFuture.class.isAssignableFrom(ctx.getAttachment().getClass())) {
24022402
return;
24032403
}
24042404

0 commit comments

Comments
 (0)