正在查看： 万能钥匙 v1.1.23 应用的 MqttService.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
万能钥匙 v1.1.23 - MqttService.java 源代码
package com.wifitutu.widget.svc.mqtt;
import ah0.l;
import android.annotation.SuppressLint;
import android.app.Service;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.net.ConnectivityManager;
import android.net.Network;
import android.net.NetworkCapabilities;
import android.net.NetworkInfo;
import android.os.Build;
import android.os.Bundle;
import android.os.IBinder;
import android.os.PowerManager;
import com.meituan.robust.ChangeQuickRedirect;
import com.meituan.robust.PatchProxy;
import com.meituan.robust.PatchProxyResult;
import com.wifitutu.widget.svc.mqtt.room.MqMessageDatabase;
import com.zm.fda.OOZ20.Z2500.OO22Z;
import java.util.Iterator;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import kotlin.Metadata;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.n;
import lg0.e0;
import pl0.b;
import pl0.e;
import pl0.f;
import pl0.k;
import pl0.o;
import qs.d6;
import rg0.d;
import vj0.C0498i;
import vj0.C0504m0;
import vj0.C0512s2;
import vj0.a1;
import vj0.l0;
import vj0.w1;
import vj0.w1$a;
import vj0.y;
import yj0.p;
import yj0.v;
@Metadata(d1 = {"\u0000ö\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0010\t\n\u0002\b\u0004\n\u0002\u0010\u0012\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u0011\n\u0002\u0010\u0015\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0010%\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\r\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0007\u0018\u0000 \u009d\u00012\u00020\u00012\u00020\u0002:\u0004\u009d\u0001\u009e\u0001B\u0007¢\u0006\u0004\b\u0003\u0010\u0004J\u000f\u0010\u0006\u001a\u00020\u0005H\u0002¢\u0006\u0004\b\u0006\u0010\u0004J\u0017\u0010\n\u001a\u00020\t2\u0006\u0010\b\u001a\u00020\u0007H\u0002¢\u0006\u0004\b\n\u0010\u000bJ\u0017\u0010\r\u001a\u00020\f2\u0006\u0010\b\u001a\u00020\u0007H\u0002¢\u0006\u0004\b\r\u0010\u000eJ!\u0010\u0011\u001a\u00020\u00052\u0006\u0010\u000f\u001a\u00020\u00072\b\u0010\u0010\u001a\u0004\u0018\u00010\u0007H\u0002¢\u0006\u0004\b\u0011\u0010\u0012J\u000f\u0010\u0013\u001a\u00020\u0005H\u0002¢\u0006\u0004\b\u0013\u0010\u0004J\u000f\u0010\u0014\u001a\u00020\u0005H\u0002¢\u0006\u0004\b\u0014\u0010\u0004J\u000f\u0010\u0015\u001a\u00020\u0005H\u0002¢\u0006\u0004\b\u0015\u0010\u0004J\u0017\u0010\u0018\u001a\u00020\f2\u0006\u0010\u0017\u001a\u00020\u0016H\u0002¢\u0006\u0004\b\u0018\u0010\u0019J\u000f\u0010\u001a\u001a\u00020\u0005H\u0016¢\u0006\u0004\b\u001a\u0010\u0004J\u000f\u0010\u001b\u001a\u00020\u0005H\u0016¢\u0006\u0004\b\u001b\u0010\u0004J\u0019\u0010\u001f\u001a\u0004\u0018\u00010\u001e2\u0006\u0010\u001d\u001a\u00020\u001cH\u0016¢\u0006\u0004\b\u001f\u0010 J)\u0010$\u001a\u00020!2\b\u0010\u001d\u001a\u0004\u0018\u00010\u001c2\u0006\u0010\"\u001a\u00020!2\u0006\u0010#\u001a\u00020!H\u0016¢\u0006\u0004\b$\u0010%J%\u0010*\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010'\u001a\u00020&2\u0006\u0010)\u001a\u00020(¢\u0006\u0004\b*\u0010+J'\u0010.\u001a\u00020\u00052\u0012\u0010-\u001a\u000e\u0012\u0004\u0012\u00020(\u0012\u0004\u0012\u00020\u00050,H\u0086@ø\u0001\u0000¢\u0006\u0004\b.\u0010/JC\u00107\u001a\u00020\u00072\u0006\u00100\u001a\u00020\u00072\u0006\u00101\u001a\u00020\u00072\u0006\u00102\u001a\u00020\u00072\b\u00104\u001a\u0004\u0018\u0001032\b\b\u0002\u00105\u001a\u00020\f2\b\b\u0002\u00106\u001a\u00020!¢\u0006\u0004\b7\u00108J)\u0010<\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\b\u0010:\u001a\u0004\u0018\u0001092\b\u0010;\u001a\u0004\u0018\u00010\u0007¢\u0006\u0004\b<\u0010=J\u0015\u0010>\u001a\u00020\u00052\u0006\u0010\u0017\u001a\u00020\u0016¢\u0006\u0004\b>\u0010?J\u0015\u0010@\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\b@\u0010AJ)\u0010C\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\b\u0010B\u001a\u0004\u0018\u00010\u00072\b\u0010;\u001a\u0004\u0018\u00010\u0007¢\u0006\u0004\bC\u0010DJ/\u0010C\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010F\u001a\u00020E2\b\u0010B\u001a\u0004\u0018\u00010\u00072\u0006\u0010;\u001a\u00020\u0007¢\u0006\u0004\bC\u0010GJ\u0015\u0010H\u001a\u00020\f2\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\bH\u0010\u000eJK\u0010P\u001a\u0004\u0018\u00010O2\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010I\u001a\u00020\u00072\u0006\u0010K\u001a\u00020J2\u0006\u0010M\u001a\u00020L2\u0006\u0010N\u001a\u00020\f2\b\u0010B\u001a\u0004\u0018\u00010\u00072\b\u0010;\u001a\u0004\u0018\u00010\u0007¢\u0006\u0004\bP\u0010QJ9\u0010P\u001a\u0004\u0018\u00010O2\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010I\u001a\u00020\u00072\u0006\u0010\u0010\u001a\u00020R2\b\u0010B\u001a\u0004\u0018\u00010\u00072\u0006\u0010;\u001a\u00020\u0007¢\u0006\u0004\bP\u0010SJ7\u0010T\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010I\u001a\u00020\u00072\u0006\u0010M\u001a\u00020L2\b\u0010B\u001a\u0004\u0018\u00010\u00072\u0006\u0010;\u001a\u00020\u0007¢\u0006\u0004\bT\u0010UJ?\u0010T\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\f\u0010I\u001a\b\u0012\u0004\u0012\u00020\u00070V2\b\u0010M\u001a\u0004\u0018\u00010W2\b\u0010B\u001a\u0004\u0018\u00010\u00072\u0006\u0010;\u001a\u00020\u0007¢\u0006\u0004\bT\u0010XJU\u0010T\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\f\u0010Y\u001a\b\u0012\u0004\u0012\u00020\u00070V2\f\u0010M\u001a\b\u0012\u0004\u0012\u00020L0V2\b\u0010B\u001a\u0004\u0018\u00010\u00072\b\u0010;\u001a\u0004\u0018\u00010\u00072\u000e\u0010[\u001a\n\u0012\u0004\u0012\u00020Z\u0018\u00010V¢\u0006\u0004\bT\u0010\\J/\u0010]\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010I\u001a\u00020\u00072\b\u0010B\u001a\u0004\u0018\u00010\u00072\u0006\u0010;\u001a\u00020\u0007¢\u0006\u0004\b]\u0010^J7\u0010]\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\f\u0010I\u001a\b\u0012\u0004\u0012\u00020\u00070V2\b\u0010B\u001a\u0004\u0018\u00010\u00072\b\u0010;\u001a\u0004\u0018\u00010\u0007¢\u0006\u0004\b]\u0010_J\u001b\u0010`\u001a\b\u0012\u0004\u0012\u00020O0V2\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\b`\u0010aJ\u001d\u0010c\u001a\u00020&2\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010b\u001a\u00020\u0007¢\u0006\u0004\bc\u0010dJ\u0017\u0010f\u001a\u00020\u00052\b\u0010e\u001a\u0004\u0018\u00010\u0007¢\u0006\u0004\bf\u0010AJ\u0019\u0010g\u001a\u00020\u00052\b\u0010\u0010\u001a\u0004\u0018\u00010\u0007H\u0016¢\u0006\u0004\bg\u0010AJ\u0019\u0010h\u001a\u00020\u00052\b\u0010\u0010\u001a\u0004\u0018\u00010\u0007H\u0016¢\u0006\u0004\bh\u0010AJ)\u0010l\u001a\u00020\u00052\b\u0010\u0010\u001a\u0004\u0018\u00010\u00072\u000e\u0010k\u001a\n\u0018\u00010ij\u0004\u0018\u0001`jH\u0016¢\u0006\u0004\bl\u0010mJ\u0015\u0010n\u001a\u00020\f2\u0006\u0010\u0017\u001a\u00020\u0016¢\u0006\u0004\bn\u0010\u0019J\u001f\u0010q\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\b\u0010p\u001a\u0004\u0018\u00010o¢\u0006\u0004\bq\u0010rJ\u0015\u0010s\u001a\u00020!2\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\bs\u0010tJ\u001d\u0010v\u001a\u00020R2\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010u\u001a\u00020!¢\u0006\u0004\bv\u0010wJ\u001d\u0010x\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010u\u001a\u00020!¢\u0006\u0004\bx\u0010yJ\u0015\u0010z\u001a\u00020!2\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\bz\u0010tR&\u0010|\u001a\u000e\u0012\u0004\u0012\u00020\u0007\u0012\u0004\u0012\u00020\t0{8\u0000X\u0080\u0004¢\u0006\f\n\u0004\b|\u0010}\u001a\u0004\b~\u0010\u007fR*\u0010\u0081\u0001\u001a\u00030\u0080\u00018\u0006@\u0006X\u0086.¢\u0006\u0018\n\u0006\b\u0081\u0001\u0010\u0082\u0001\u001a\u0006\b\u0083\u0001\u0010\u0084\u0001\"\u0006\b\u0085\u0001\u0010\u0086\u0001R\u0019\u0010e\u001a\u0004\u0018\u00010\u00078\u0002@\u0002X\u0082\u000e¢\u0006\u0007\n\u0005\be\u0010\u0087\u0001R\u0019\u0010\u0088\u0001\u001a\u00020\f8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0088\u0001\u0010\u0089\u0001R)\u0010\u008a\u0001\u001a\u00020\f8\u0006@\u0006X\u0086\u000e¢\u0006\u0018\n\u0006\b\u008a\u0001\u0010\u0089\u0001\u001a\u0006\b\u008a\u0001\u0010\u008b\u0001\"\u0006\b\u008c\u0001\u0010\u008d\u0001R \u0010\u008f\u0001\u001a\t\u0018\u00010\u008e\u0001R\u00020\u00008\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u008f\u0001\u0010\u0090\u0001R\u001c\u0010\u0092\u0001\u001a\u0005\u0018\u00010\u0091\u00018\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0092\u0001\u0010\u0093\u0001R\u001c\u0010\u0095\u0001\u001a\u0005\u0018\u00010\u0094\u00018\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0095\u0001\u0010\u0096\u0001R\u001c\u0010\u0098\u0001\u001a\u0005\u0018\u00010\u0097\u00018\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0098\u0001\u0010\u0099\u0001R\u001e\u0010\u009b\u0001\u001a\t\u0012\u0004\u0012\u00020(0\u009a\u00018\u0002X\u0082\u0004¢\u0006\b\n\u0006\b\u009b\u0001\u0010\u009c\u0001\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u009f\u0001"}, d2 = {"Lcom/wifitutu/widget/svc/mqtt/MqttService;", "Landroid/app/Service;", "Lcom/wifitutu/widget/svc/mqtt/MqttTraceHandler;", "<init>", "()V", "Llg0/e0;", "stopService", "", "clientHandle", "Lcom/wifitutu/widget/svc/mqtt/MqttConnection;", "getConnection", "(Ljava/lang/String;)Lcom/wifitutu/widget/svc/mqtt/MqttConnection;", "", "isConnectionAvailable", "(Ljava/lang/String;)Z", "severity", "message", "traceCallback", "(Ljava/lang/String;Ljava/lang/String;)V", "registerBroadcastReceivers", "unregisterBroadcastReceivers", "notifyClientsOffline", "Landroid/content/Context;", "context", "isInternetAvailable", "(Landroid/content/Context;)Z", "onCreate", "onDestroy", "Landroid/content/Intent;", "intent", "Landroid/os/IBinder;", "onBind", "(Landroid/content/Intent;)Landroid/os/IBinder;", "", "flags", "startId", "onStartCommand", "(Landroid/content/Intent;II)I", "Lcom/wifitutu/widget/svc/mqtt/Status;", "status", "Landroid/os/Bundle;", "dataBundle", "callbackToActivity", "(Ljava/lang/String;Lcom/wifitutu/widget/svc/mqtt/Status;Landroid/os/Bundle;)V", "Lkotlin/Function1;", "block", "collect", "(Lah0/l;Lrg0/d;)Ljava/lang/Object;", "serverURI", "clientId", "contextId", "Lpl0/k;", "persistence", "pingLogging", "keepPingRecords", "getClient", "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lpl0/k;ZI)Ljava/lang/String;", "Lpl0/l;", "connectOptions", "activityToken", "connect", "(Ljava/lang/String;Lpl0/l;Ljava/lang/String;)V", "reconnect", "(Landroid/content/Context;)V", "close", "(Ljava/lang/String;)V", "invocationContext", "disconnect", "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V", "", "quiesceTimeout", "(Ljava/lang/String;JLjava/lang/String;Ljava/lang/String;)V", "isConnected", "topic", "", "payload", "Lcom/wifitutu/widget/svc/mqtt/QoS;", "qos", "retained", "Lpl0/e;", "publish", "(Ljava/lang/String;Ljava/lang/String;[BLcom/wifitutu/widget/svc/mqtt/QoS;ZLjava/lang/String;Ljava/lang/String;)Lpl0/e;", "Lpl0/o;", "(Ljava/lang/String;Ljava/lang/String;Lpl0/o;Ljava/lang/String;Ljava/lang/String;)Lpl0/e;", "subscribe", "(Ljava/lang/String;Ljava/lang/String;Lcom/wifitutu/widget/svc/mqtt/QoS;Ljava/lang/String;Ljava/lang/String;)V", "", "", "(Ljava/lang/String;[Ljava/lang/String;[ILjava/lang/String;Ljava/lang/String;)V", "topicFilters", "Lpl0/f;", "messageListeners", "(Ljava/lang/String;[Ljava/lang/String;[Lcom/wifitutu/widget/svc/mqtt/QoS;Ljava/lang/String;Ljava/lang/String;[Lpl0/f;)V", "unsubscribe", "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V", "(Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V", "getPendingDeliveryTokens", "(Ljava/lang/String;)[Lpl0/e;", "id", "acknowledgeMessageArrival", "(Ljava/lang/String;Ljava/lang/String;)Lcom/wifitutu/widget/svc/mqtt/Status;", "traceCallbackId", "setTraceCallbackId", "traceDebug", "traceError", "Ljava/lang/Exception;", "Lkotlin/Exception;", "e", "traceException", "(Ljava/lang/String;Ljava/lang/Exception;)V", "isOnline", "Lpl0/b;", "bufferOpts", "setBufferOpts", "(Ljava/lang/String;Lpl0/b;)V", "getBufferedMessageCount", "(Ljava/lang/String;)I", "bufferIndex", "getBufferedMessage", "(Ljava/lang/String;I)Lpl0/o;", "deleteBufferedMessage", "(Ljava/lang/String;I)V", "getInFlightMessageCount", "", "connections", "Ljava/util/Map;", "getConnections$svc_mqtt_release", "()Ljava/util/Map;", "Lcom/wifitutu/widget/svc/mqtt/room/MqMessageDatabase;", "messageDatabase", "Lcom/wifitutu/widget/svc/mqtt/room/MqMessageDatabase;", "getMessageDatabase", "()Lcom/wifitutu/widget/svc/mqtt/room/MqMessageDatabase;", "setMessageDatabase", "(Lcom/wifitutu/widget/svc/mqtt/room/MqMessageDatabase;)V", "Ljava/lang/String;", "isForegroundStarted", "Z", "isTraceEnabled", "()Z", "setTraceEnabled", "(Z)V", "Lcom/wifitutu/widget/svc/mqtt/MqttService$NetworkConnectionIntentReceiver;", "networkConnectionMonitor", "Lcom/wifitutu/widget/svc/mqtt/MqttService$NetworkConnectionIntentReceiver;", "Lcom/wifitutu/widget/svc/mqtt/MqttServiceBinder;", "mqttServiceBinder", "Lcom/wifitutu/widget/svc/mqtt/MqttServiceBinder;", "Lvj0/w1;", "serviceJob", "Lvj0/w1;", "Lvj0/l0;", "serviceScope", "Lvj0/l0;", "Lyj0/p;", "flow", "Lyj0/p;", "Companion", "NetworkConnectionIntentReceiver", "svc-mqtt_release"}, k = 1, mv = {1, 8, 0}, xi = 48)
@SuppressLint({"Registered"})
public final class MqttService extends Service implements MqttTraceHandler {
public static ChangeQuickRedirect changeQuickRedirect;
private final Map<String, MqttConnection> connections = new ConcurrentHashMap();
private final p<Bundle> flow = v.b(0, 0, null, 7, null);
private boolean isForegroundStarted;
private boolean isTraceEnabled;
public MqMessageDatabase messageDatabase;
private MqttServiceBinder mqttServiceBinder;
private NetworkConnectionIntentReceiver networkConnectionMonitor;
private w1 serviceJob;
private l0 serviceScope;
private String traceCallbackId;
public static final Companion INSTANCE = new Companion(null);
private static final String MQTT_FOREGROUND_SERVICE_NOTIFICATION_ID = MqttService.class.getSimpleName() + ".FOREGROUND_SERVICE_NOTIFICATION_ID";
private static final String MQTT_FOREGROUND_SERVICE_NOTIFICATION = MqttService.class.getSimpleName() + ".FOREGROUND_SERVICE_NOTIFICATION";
@Metadata(d1 = {"\u0000\u0014\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0005\b\u0086\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002R\u0011\u0010\u0003\u001a\u00020\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0005\u0010\u0006R\u0011\u0010\u0007\u001a\u00020\u0004¢\u0006\b\n\u0000\u001a\u0004\b\b\u0010\u0006¨\u0006\t"}, d2 = {"Lcom/wifitutu/widget/svc/mqtt/MqttService$Companion;", "", "()V", "MQTT_FOREGROUND_SERVICE_NOTIFICATION", "", "getMQTT_FOREGROUND_SERVICE_NOTIFICATION", "()Ljava/lang/String;", "MQTT_FOREGROUND_SERVICE_NOTIFICATION_ID", "getMQTT_FOREGROUND_SERVICE_NOTIFICATION_ID", "svc-mqtt_release"}, k = 1, mv = {1, 8, 0}, xi = 48)
public static final class Companion {
public static ChangeQuickRedirect changeQuickRedirect;
private Companion() {
}
public Companion(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
public final String getMQTT_FOREGROUND_SERVICE_NOTIFICATION() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39817, new Class[0], String.class);
return proxy.isSupported ? (String) proxy.result : MqttService.MQTT_FOREGROUND_SERVICE_NOTIFICATION;
}
public final String getMQTT_FOREGROUND_SERVICE_NOTIFICATION_ID() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39816, new Class[0], String.class);
return proxy.isSupported ? (String) proxy.result : MqttService.MQTT_FOREGROUND_SERVICE_NOTIFICATION_ID;
}
}
@Metadata(d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\b\u0082\u0004\u0018\u00002\u00020\u0001B\u0007¢\u0006\u0004\b\u0002\u0010\u0003J\u001f\u0010\t\u001a\u00020\b2\u0006\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0007\u001a\u00020\u0006H\u0017¢\u0006\u0004\b\t\u0010\n¨\u0006\u000b"}, d2 = {"Lcom/wifitutu/widget/svc/mqtt/MqttService$NetworkConnectionIntentReceiver;", "Landroid/content/BroadcastReceiver;", "<init>", "(Lcom/wifitutu/widget/svc/mqtt/MqttService;)V", "Landroid/content/Context;", "context", "Landroid/content/Intent;", "intent", "Llg0/e0;", "onReceive", "(Landroid/content/Context;Landroid/content/Intent;)V", "svc-mqtt_release"}, k = 1, mv = {1, 8, 0}, xi = 48)
public final class NetworkConnectionIntentReceiver extends BroadcastReceiver {
public static ChangeQuickRedirect changeQuickRedirect;
public NetworkConnectionIntentReceiver() {
}
@Override
@SuppressLint({"Wakelock"})
public void onReceive(Context context, Intent intent) {
if (PatchProxy.proxy(new Object[]{context, intent}, this, changeQuickRedirect, false, 39818, new Class[]{Context.class, Intent.class}, Void.TYPE).isSupported) {
return;
}
MqttService.this.traceDebug("Internal network status receive.");
Object systemService = MqttService.this.getSystemService("power");
n.g(systemService, "null cannot be cast to non-null type android.os.PowerManager");
PowerManager.WakeLock newWakeLock = ((PowerManager) systemService).newWakeLock(1, "MQTT:tag");
newWakeLock.acquire(600000L);
MqttService.this.traceDebug("Reconnect for Network recovery.");
if (MqttService.this.isOnline(context)) {
MqttService.this.traceDebug("Online,reconnect.");
MqttService.this.reconnect(context);
} else {
MqttService.access$notifyClientsOffline(MqttService.this);
}
newWakeLock.release();
}
}
public static final Object access$collect$suspendConversion0(l lVar, Bundle bundle, d dVar) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{lVar, bundle, dVar}, (Object) null, changeQuickRedirect, true, 39813, new Class[]{l.class, Bundle.class, d.class}, Object.class);
return proxy.isSupported ? proxy.result : collect$suspendConversion0(lVar, bundle, dVar);
}
public static final boolean access$isInternetAvailable(MqttService mqttService, Context context) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{mqttService, context}, (Object) null, changeQuickRedirect, true, 39814, new Class[]{MqttService.class, Context.class}, Boolean.TYPE);
return proxy.isSupported ? ((Boolean) proxy.result).booleanValue() : mqttService.isInternetAvailable(context);
}
public static final void access$notifyClientsOffline(MqttService mqttService) {
if (PatchProxy.proxy(new Object[]{mqttService}, (Object) null, changeQuickRedirect, true, 39815, new Class[]{MqttService.class}, Void.TYPE).isSupported) {
return;
}
mqttService.notifyClientsOffline();
}
private static final Object collect$suspendConversion0(l lVar, Bundle bundle, d dVar) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{lVar, bundle, dVar}, (Object) null, changeQuickRedirect, true, 39812, new Class[]{l.class, Bundle.class, d.class}, Object.class);
if (proxy.isSupported) {
return proxy.result;
}
lVar.invoke(bundle);
return e0.a;
}
public static String getClient$default(MqttService mqttService, String str, String str2, String str3, k kVar, boolean z, int i, int i2, Object obj) {
int i3;
MqttService mqttService2;
String str4;
String str5;
k kVar2;
String str6;
Object[] objArr = {mqttService, str, str2, str3, kVar, new Byte(z ? (byte) 1 : (byte) 0), new Integer(i), new Integer(i2), obj};
ChangeQuickRedirect changeQuickRedirect2 = changeQuickRedirect;
Class cls = Integer.TYPE;
PatchProxyResult proxy = PatchProxy.proxy(objArr, (Object) null, changeQuickRedirect2, true, 39779, new Class[]{MqttService.class, String.class, String.class, String.class, k.class, Boolean.TYPE, cls, cls, Object.class}, String.class);
if (proxy.isSupported) {
return (String) proxy.result;
}
boolean z2 = (i2 & 16) != 0 ? false : z ? 1 : 0;
if ((i2 & 32) != 0) {
i3 = OO22Z.l;
mqttService2 = mqttService;
str4 = str;
str6 = str2;
str5 = str3;
kVar2 = kVar;
} else {
i3 = i;
mqttService2 = mqttService;
str4 = str;
str5 = str3;
kVar2 = kVar;
str6 = str2;
}
return mqttService2.getClient(str4, str6, str5, kVar2, z2, i3);
}
private final MqttConnection getConnection(String clientHandle) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle}, this, changeQuickRedirect, false, 39795, new Class[]{String.class}, MqttConnection.class);
if (proxy.isSupported) {
return (MqttConnection) proxy.result;
}
MqttConnection mqttConnection = this.connections.get(clientHandle);
if (mqttConnection != null) {
return mqttConnection;
}
throw new IllegalArgumentException("Invalid ClientHandle >" + clientHandle + '<');
}
private final boolean isConnectionAvailable(String clientHandle) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle}, this, changeQuickRedirect, false, 39796, new Class[]{String.class}, Boolean.TYPE);
return proxy.isSupported ? ((Boolean) proxy.result).booleanValue() : this.connections.containsKey(clientHandle);
}
private final boolean isInternetAvailable(Context context) {
NetworkCapabilities networkCapabilities;
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{context}, this, changeQuickRedirect, false, 39806, new Class[]{Context.class}, Boolean.TYPE);
if (proxy.isSupported) {
return ((Boolean) proxy.result).booleanValue();
}
Object systemService = context.getSystemService("connectivity");
n.g(systemService, "null cannot be cast to non-null type android.net.ConnectivityManager");
ConnectivityManager connectivityManager = (ConnectivityManager) systemService;
if (Build.VERSION.SDK_INT >= 23) {
Network activeNetwork = connectivityManager.getActiveNetwork();
if (activeNetwork == null || (networkCapabilities = connectivityManager.getNetworkCapabilities(activeNetwork)) == null) {
return false;
}
return networkCapabilities.hasTransport(1) || networkCapabilities.hasTransport(0) || networkCapabilities.hasTransport(3);
}
NetworkInfo activeNetworkInfo = connectivityManager.getActiveNetworkInfo();
if (activeNetworkInfo == null) {
return false;
}
int type = activeNetworkInfo.getType();
return type == 0 || type == 1 || type == 9;
}
private final void notifyClientsOffline() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39805, new Class[0], Void.TYPE).isSupported) {
return;
}
Iterator<T> it = this.connections.values().iterator();
while (it.hasNext()) {
((MqttConnection) it.next()).offline();
}
}
private final void registerBroadcastReceivers() {
if (!PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39802, new Class[0], Void.TYPE).isSupported && this.networkConnectionMonitor == null) {
NetworkConnectionIntentReceiver networkConnectionIntentReceiver = new NetworkConnectionIntentReceiver();
this.networkConnectionMonitor = networkConnectionIntentReceiver;
registerReceiver(networkConnectionIntentReceiver, new IntentFilter("android.net.conn.CONNECTIVITY_CHANGE"));
}
}
private final void stopService() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39783, new Class[0], Void.TYPE).isSupported) {
return;
}
if (this.isForegroundStarted) {
if (Build.VERSION.SDK_INT >= 24) {
stopForeground(1);
} else {
stopForeground(true);
}
}
stopSelf();
}
private final void traceCallback(String severity, String message) {
String str;
if (PatchProxy.proxy(new Object[]{severity, message}, this, changeQuickRedirect, false, 39800, new Class[]{String.class, String.class}, Void.TYPE).isSupported || (str = this.traceCallbackId) == null || !this.isTraceEnabled) {
return;
}
Bundle bundle = new Bundle();
bundle.putString(".callbackAction", "trace");
bundle.putString(".traceSeverity", severity);
bundle.putString(".errorMessage", message);
callbackToActivity(str, Status.ERROR, bundle);
}
private final void unregisterBroadcastReceivers() {
NetworkConnectionIntentReceiver networkConnectionIntentReceiver;
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39803, new Class[0], Void.TYPE).isSupported || (networkConnectionIntentReceiver = this.networkConnectionMonitor) == null) {
return;
}
unregisterReceiver(networkConnectionIntentReceiver);
this.networkConnectionMonitor = null;
}
public final Status acknowledgeMessageArrival(String clientHandle, String id) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle, id}, this, changeQuickRedirect, false, 39797, new Class[]{String.class, String.class}, Status.class);
return proxy.isSupported ? (Status) proxy.result : getMessageDatabase().discardArrived(clientHandle, id) ? Status.OK : Status.ERROR;
}
public final void callbackToActivity(String clientHandle, Status status, Bundle dataBundle) {
if (PatchProxy.proxy(new Object[]{clientHandle, status, dataBundle}, this, changeQuickRedirect, false, 39776, new Class[]{String.class, Status.class, Bundle.class}, Void.TYPE).isSupported) {
return;
}
Bundle bundle = new Bundle(dataBundle);
bundle.putString(".clientHandle", clientHandle);
bundle.putSerializable(".callbackStatus", status);
l0 l0Var = this.serviceScope;
if (l0Var != null) {
C0498i.d(l0Var, null, null, new MqttService$callbackToActivity$1(this, bundle, null), 3, null);
}
}
public final void close(String clientHandle) {
if (PatchProxy.proxy(new Object[]{clientHandle}, this, changeQuickRedirect, false, 39782, new Class[]{String.class}, Void.TYPE).isSupported) {
return;
}
getConnection(clientHandle).close();
}
public final java.lang.Object collect(ah0.l<? super android.os.Bundle, lg0.e0> r10, rg0.d<? super lg0.e0> r11) {
throw new UnsupportedOperationException("Method not decompiled: com.wifitutu.widget.svc.mqtt.MqttService.collect(ah0.l, rg0.d):java.lang.Object");
}
public final void connect(String clientHandle, pl0.l connectOptions, String activityToken) throws pl0.n {
if (PatchProxy.proxy(new Object[]{clientHandle, connectOptions, activityToken}, this, changeQuickRedirect, false, 39780, new Class[]{String.class, pl0.l.class, String.class}, Void.TYPE).isSupported) {
return;
}
C0498i.d(C0504m0.a(a1.b()), null, null, new MqttService$connect$1(getConnection(clientHandle), connectOptions, activityToken, null), 3, null);
}
public final void deleteBufferedMessage(String clientHandle, int bufferIndex) {
if (PatchProxy.proxy(new Object[]{clientHandle, new Integer(bufferIndex)}, this, changeQuickRedirect, false, 39810, new Class[]{String.class, Integer.TYPE}, Void.TYPE).isSupported) {
return;
}
getConnection(clientHandle).deleteBufferedMessage(bufferIndex);
}
public final void disconnect(String clientHandle, long quiesceTimeout, String invocationContext, String activityToken) {
if (PatchProxy.proxy(new Object[]{clientHandle, new Long(quiesceTimeout), invocationContext, activityToken}, this, changeQuickRedirect, false, 39785, new Class[]{String.class, Long.TYPE, String.class, String.class}, Void.TYPE).isSupported) {
return;
}
getConnection(clientHandle).disconnect(quiesceTimeout, invocationContext, activityToken);
this.connections.remove(clientHandle);
stopService();
}
public final void disconnect(String clientHandle, String invocationContext, String activityToken) {
if (PatchProxy.proxy(new Object[]{clientHandle, invocationContext, activityToken}, this, changeQuickRedirect, false, 39784, new Class[]{String.class, String.class, String.class}, Void.TYPE).isSupported) {
return;
}
if (!isConnectionAvailable(clientHandle)) {
stopService();
} else {
getConnection(clientHandle).disconnect(invocationContext, activityToken);
this.connections.remove(clientHandle);
}
}
public final o getBufferedMessage(String clientHandle, int bufferIndex) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle, new Integer(bufferIndex)}, this, changeQuickRedirect, false, 39809, new Class[]{String.class, Integer.TYPE}, o.class);
return proxy.isSupported ? (o) proxy.result : getConnection(clientHandle).getBufferedMessage(bufferIndex);
}
public final int getBufferedMessageCount(String clientHandle) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle}, this, changeQuickRedirect, false, 39808, new Class[]{String.class}, Integer.TYPE);
return proxy.isSupported ? ((Integer) proxy.result).intValue() : getConnection(clientHandle).getBufferedMessageCount();
}
public final String getClient(String serverURI, String clientId, String contextId, k persistence, boolean pingLogging, int keepPingRecords) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{serverURI, clientId, contextId, persistence, new Byte(pingLogging ? (byte) 1 : (byte) 0), new Integer(keepPingRecords)}, this, changeQuickRedirect, false, 39778, new Class[]{String.class, String.class, String.class, k.class, Boolean.TYPE, Integer.TYPE}, String.class);
if (proxy.isSupported) {
return (String) proxy.result;
}
String str = serverURI + ':' + clientId + ':' + contextId;
if (!this.connections.containsKey(str)) {
this.connections.put(str, new MqttConnection(this, serverURI, clientId, persistence, str, pingLogging, keepPingRecords));
}
return str;
}
public final Map<String, MqttConnection> getConnections$svc_mqtt_release() {
return this.connections;
}
public final int getInFlightMessageCount(String clientHandle) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle}, this, changeQuickRedirect, false, 39811, new Class[]{String.class}, Integer.TYPE);
return proxy.isSupported ? ((Integer) proxy.result).intValue() : getConnection(clientHandle).getInFlightMessageCount();
}
public final MqMessageDatabase getMessageDatabase() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39771, new Class[0], MqMessageDatabase.class);
if (proxy.isSupported) {
return (MqMessageDatabase) proxy.result;
}
MqMessageDatabase mqMessageDatabase = this.messageDatabase;
if (mqMessageDatabase != null) {
return mqMessageDatabase;
}
n.z("messageDatabase");
return null;
}
public final e[] getPendingDeliveryTokens(String clientHandle) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle}, this, changeQuickRedirect, false, 39794, new Class[]{String.class}, e[].class);
return proxy.isSupported ? (e[]) proxy.result : getConnection(clientHandle).getPendingDeliveryTokens();
}
public final boolean isConnected(String clientHandle) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle}, this, changeQuickRedirect, false, 39786, new Class[]{String.class}, Boolean.TYPE);
if (proxy.isSupported) {
return ((Boolean) proxy.result).booleanValue();
}
if (isConnectionAvailable(clientHandle)) {
return getConnection(clientHandle).isConnected();
}
return false;
}
public final boolean isOnline(Context context) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{context}, this, changeQuickRedirect, false, 39804, new Class[]{Context.class}, Boolean.TYPE);
return proxy.isSupported ? ((Boolean) proxy.result).booleanValue() : ((Boolean) d6.j(Boolean.FALSE, new MqttService$isOnline$1(this, context))).booleanValue();
}
public final boolean getIsTraceEnabled() {
return this.isTraceEnabled;
}
@Override
public IBinder onBind(Intent intent) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{intent}, this, changeQuickRedirect, false, 39774, new Class[]{Intent.class}, IBinder.class);
if (proxy.isSupported) {
return (IBinder) proxy.result;
}
String stringExtra = intent.getStringExtra(".activityToken");
MqttServiceBinder mqttServiceBinder = this.mqttServiceBinder;
n.f(mqttServiceBinder);
mqttServiceBinder.setActivityToken(stringExtra);
return this.mqttServiceBinder;
}
@Override
public void onCreate() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39772, new Class[0], Void.TYPE).isSupported) {
return;
}
super.onCreate();
y b = C0512s2.b(null, 1, null);
this.serviceJob = b;
this.serviceScope = C0504m0.a(a1.c().u(b));
this.mqttServiceBinder = new MqttServiceBinder(this);
setMessageDatabase(MqMessageDatabase.Companion.getDatabase$default(MqMessageDatabase.INSTANCE, this, null, 2, null));
}
@Override
public void onDestroy() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 39773, new Class[0], Void.TYPE).isSupported) {
return;
}
Iterator<MqttConnection> it = this.connections.values().iterator();
while (it.hasNext()) {
it.next().disconnect(null, null);
}
w1 w1Var = this.serviceJob;
if (w1Var != null) {
w1$a.a(w1Var, null, 1, null);
}
this.serviceJob = null;
this.serviceScope = null;
this.mqttServiceBinder = null;
unregisterBroadcastReceivers();
super.onDestroy();
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
Object[] objArr = {intent, new Integer(flags), new Integer(startId)};
ChangeQuickRedirect changeQuickRedirect2 = changeQuickRedirect;
Class cls = Integer.TYPE;
PatchProxyResult proxy = PatchProxy.proxy(objArr, this, changeQuickRedirect2, false, 39775, new Class[]{Intent.class, cls, cls}, cls);
if (proxy.isSupported) {
return ((Integer) proxy.result).intValue();
}
registerBroadcastReceivers();
return 1;
}
public final e publish(String clientHandle, String topic, o message, String invocationContext, String activityToken) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle, topic, message, invocationContext, activityToken}, this, changeQuickRedirect, false, 39788, new Class[]{String.class, String.class, o.class, String.class, String.class}, e.class);
return proxy.isSupported ? (e) proxy.result : getConnection(clientHandle).publish(topic, message, invocationContext, activityToken);
}
public final e publish(String clientHandle, String topic, byte[] payload, QoS qos, boolean retained, String invocationContext, String activityToken) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{clientHandle, topic, payload, qos, new Byte(retained ? (byte) 1 : (byte) 0), invocationContext, activityToken}, this, changeQuickRedirect, false, 39787, new Class[]{String.class, String.class, byte[].class, QoS.class, Boolean.TYPE, String.class, String.class}, e.class);
if (proxy.isSupported) {
return (e) proxy.result;
}
MqttConnection connection = getConnection(clientHandle);
n.f(activityToken);
return connection.publish(topic, payload, qos, retained, invocationContext, activityToken);
}
public final void reconnect(Context context) {
if (PatchProxy.proxy(new Object[]{context}, this, changeQuickRedirect, false, 39781, new Class[]{Context.class}, Void.TYPE).isSupported) {
return;
}
traceDebug("Reconnect to server, client size=" + this.connections.size());
for (MqttConnection mqttConnection : this.connections.values()) {
traceDebug("Reconnect Client:" + mqttConnection.getClientId() + '/' + mqttConnection.getServerURI());
if (isOnline(context)) {
mqttConnection.reconnect(context);
}
}
}
public final void setBufferOpts(String clientHandle, b bufferOpts) {
if (PatchProxy.proxy(new Object[]{clientHandle, bufferOpts}, this, changeQuickRedirect, false, 39807, new Class[]{String.class, b.class}, Void.TYPE).isSupported) {
return;
}
getConnection(clientHandle).setBufferOpts(bufferOpts);
}
public final void setMessageDatabase(MqMessageDatabase mqMessageDatabase) {
this.messageDatabase = mqMessageDatabase;
}
public final void setTraceCallbackId(String traceCallbackId) {
this.traceCallbackId = traceCallbackId;
}
public final void setTraceEnabled(boolean z) {
this.isTraceEnabled = z;
}
public final void subscribe(String clientHandle, String topic, QoS qos, String invocationContext, String activityToken) {
if (PatchProxy.proxy(new Object[]{clientHandle, topic, qos, invocationContext, activityToken}, this, changeQuickRedirect, false, 39789, new Class[]{String.class, String.class, QoS.class, String.class, String.class}, Void.TYPE).isSupported) {
return;
}
getConnection(clientHandle).subscribe(topic, qos, invocationContext, activityToken);
}
public final void subscribe(String clientHandle, String[] topic, int[] qos, String invocationContext, String activityToken) {
if (PatchProxy.proxy(new Object[]{clientHandle, topic, qos, invocationContext, activityToken}, this, changeQuickRedirect, false, 39790, new Class[]{String.class, String[].class, int[].class, String.class, String.class}, Void.TYPE).isSupported) {
return;
}
getConnection(clientHandle).subscribe(topic, qos, invocationContext, activityToken);
}
public final void subscribe(String clientHandle, String[] topicFilters, QoS[] qos, String invocationContext, String activityToken, f[] messageListeners) {
if (PatchProxy.proxy(new Object[]{clientHandle, topicFilters, qos, invocationContext, activityToken, messageListeners}, this, changeQuickRedirect, false, 39791, new Class[]{String.class, String[].class, QoS[].class, String.class, String.class, f[].class}, Void.TYPE).isSupported) {
return;
}
MqttConnection connection = getConnection(clientHandle);
n.f(activityToken);
connection.subscribe(topicFilters, qos, invocationContext, activityToken, messageListeners);
}
@Override
public void traceDebug(String message) {
if (PatchProxy.proxy(new Object[]{message}, this, changeQuickRedirect, false, 39798, new Class[]{String.class}, Void.TYPE).isSupported) {
return;
}
traceCallback("debug", message);
}
@Override
public void traceError(String message) {
if (PatchProxy.proxy(new Object[]{message}, this, changeQuickRedirect, false, 39799, new Class[]{String.class}, Void.TYPE).isSupported) {
return;
}
traceCallback("error", message);
}
@Override
public void traceException(String message, Exception e) {
String str;
if (PatchProxy.proxy(new Object[]{message, e}, this, changeQuickRedirect, false, 39801, new Class[]{String.class, Exception.class}, Void.TYPE).isSupported || (str = this.traceCallbackId) == null) {
return;
}
Bundle bundle = new Bundle();
bundle.putString(".callbackAction", "trace");
bundle.putString(".traceSeverity", "exception");
bundle.putString(".errorMessage", message);
bundle.putSerializable(".exception", e);
callbackToActivity(str, Status.ERROR, bundle);
}
public final void unsubscribe(String clientHandle, String topic, String invocationContext, String activityToken) {
if (PatchProxy.proxy(new Object[]{clientHandle, topic, invocationContext, activityToken}, this, changeQuickRedirect, false, 39792, new Class[]{String.class, String.class, String.class, String.class}, Void.TYPE).isSupported) {
return;
}
getConnection(clientHandle).unsubscribe(topic, invocationContext, activityToken);
}
public final void unsubscribe(String clientHandle, String[] topic, String invocationContext, String activityToken) {
if (PatchProxy.proxy(new Object[]{clientHandle, topic, invocationContext, activityToken}, this, changeQuickRedirect, false, 39793, new Class[]{String.class, String[].class, String.class, String.class}, Void.TYPE).isSupported) {
return;
}
MqttConnection connection = getConnection(clientHandle);
n.f(activityToken);
connection.unsubscribe(topic, invocationContext, activityToken);
}
}