Fix npe with pulsar and ssl (#9166)
This commit is contained in:
parent
54d0e0718f
commit
6eec23c00b
|
@ -94,7 +94,8 @@ public final class NettySslInstrumentationHandler extends ChannelDuplexHandler {
|
||||||
promise.addListener(
|
promise.addListener(
|
||||||
future -> {
|
future -> {
|
||||||
// there won't be any SSL handshake if the channel fails to connect
|
// there won't be any SSL handshake if the channel fails to connect
|
||||||
if (!future.isSuccess()) {
|
// give up when channelRegistered wasn't called and parentContext is null
|
||||||
|
if (!future.isSuccess() || parentContext == null) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
request = NettySslRequest.create(ctx.channel());
|
request = NettySslRequest.create(ctx.channel());
|
||||||
|
|
Loading…
Reference in New Issue