|
|
@ -1069,7 +1069,6 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public void onDeviceDeleted(DeviceId deviceId) { |
|
|
public void onDeviceDeleted(DeviceId deviceId) { |
|
|
doDisconnect(); |
|
|
|
|
|
context.onAuthFailure(address); |
|
|
context.onAuthFailure(address); |
|
|
ChannelHandlerContext ctx = deviceSessionCtx.getChannel(); |
|
|
ChannelHandlerContext ctx = deviceSessionCtx.getChannel(); |
|
|
ctx.close(); |
|
|
ctx.close(); |
|
|
|