|
|
|
@ -929,9 +929,6 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement |
|
|
|
gatewaySessionHandler.onGatewayDisconnect(); |
|
|
|
} |
|
|
|
deviceSessionCtx.setDisconnected(); |
|
|
|
context.onAuthFailure(address); |
|
|
|
ChannelHandlerContext ctx = deviceSessionCtx.getChannel(); |
|
|
|
ctx.close(); |
|
|
|
} |
|
|
|
deviceSessionCtx.release(); |
|
|
|
} |
|
|
|
@ -1073,6 +1070,9 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement |
|
|
|
@Override |
|
|
|
public void onDeviceDeleted(DeviceId deviceId) { |
|
|
|
doDisconnect(); |
|
|
|
context.onAuthFailure(address); |
|
|
|
ChannelHandlerContext ctx = deviceSessionCtx.getChannel(); |
|
|
|
ctx.close(); |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|