public class org.fusesource.mqtt.client.CallbackConnection extends java.lang.Object { private static final org.fusesource.mqtt.client.ExtendedListener DEFAULT_LISTENER; private final org.fusesource.hawtdispatch.DispatchQueue queue; private final org.fusesource.mqtt.client.MQTT mqtt; private org.fusesource.hawtdispatch.transport.Transport transport; private org.fusesource.mqtt.client.ExtendedListener listener; private java.lang.Runnable refiller; private java.util.Map requests; private java.util.LinkedList overflow; private final java.util.HashMap processed; private java.lang.Throwable failure; private boolean disconnected; private org.fusesource.hawtdispatch.transport.HeartBeatMonitor heartBeatMonitor; private long pingedAt; private long reconnects; private java.util.concurrent.atomic.AtomicBoolean isReconnecting; private final java.util.concurrent.atomic.AtomicInteger suspendCount; private final java.util.concurrent.atomic.AtomicInteger suspendChanges; private final java.util.HashMap activeSubs; private final java.lang.Object nextMessageIdLock; private boolean onRefillCalled; private short nextMessageId; public static final org.fusesource.hawtdispatch.Task NOOP; static final boolean $assertionsDisabled; public void (org.fusesource.mqtt.client.MQTT) { org.fusesource.mqtt.client.MQTT v, v, v; java.util.concurrent.atomic.AtomicBoolean v; java.util.HashMap v, v; org.fusesource.mqtt.client.CallbackConnection v; java.util.concurrent.atomic.AtomicInteger v, v; java.util.LinkedList v; java.util.concurrent.ConcurrentHashMap v; org.fusesource.hawtdispatch.DispatchQueue v, v, v; org.fusesource.mqtt.client.ExtendedListener v; java.lang.Object v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.MQTT; specialinvoke v.()>(); v = ; v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.LinkedList; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v. = 0; v. = 0L; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v. = 0; v. = 1; v. = v; v = v.; v = v.; if v != null goto label; v = staticinvoke ("mqtt client"); v. = v; goto label; label: v = v.; v = v.; v. = v; label: return; } public void connect(org.fusesource.mqtt.client.Callback) { java.lang.Throwable v; java.lang.IllegalStateException v; java.lang.AssertionError v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v; org.fusesource.hawtdispatch.transport.Transport v; org.fusesource.mqtt.client.CallbackConnection$LoginHandler v; boolean v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.Callback; v = ; if v != 0 goto label; if v != null goto label; v = new java.lang.AssertionError; specialinvoke v.(java.lang.Object)>("Callback should not be null."); throw v; label: v = v.; if v == null goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Already connected"); interfaceinvoke v.(v); return; label: v = new org.fusesource.mqtt.client.CallbackConnection$LoginHandler; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,org.fusesource.mqtt.client.Callback,boolean)>(v, v, 1); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; interfaceinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } private long calculateDelay() { org.fusesource.mqtt.client.MQTT v, v, v, v, v; long v, v, v, v, v, v, v, v; org.fusesource.mqtt.client.CallbackConnection v; byte v, v; double v, v, v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; v = v.; v = v cmp 0L; if v <= 0 goto label; v = v.; v = v.; v = v cmpl 1.0; if v <= 0 goto label; v = v.; v = v.; v = v.; v = v * v; v = v.; v = v.; v = staticinvoke (v, v); label: v = v.; v = v.; v = staticinvoke (v, v); v = v.; v = v + 1L; v. = v; return v; } void reconnect() { java.lang.Throwable v; java.util.concurrent.atomic.AtomicBoolean v, v; long v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.CallbackConnection$2 v; java.lang.InterruptedException v; org.fusesource.mqtt.client.CallbackConnection$LoginHandler v; boolean v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; v = virtualinvoke v.(1); if v == 0 goto label; return; label: v = specialinvoke v.(); label: staticinvoke (v); label: goto label; label: v := @caughtexception; label: v = new org.fusesource.mqtt.client.CallbackConnection$LoginHandler; v = new org.fusesource.mqtt.client.CallbackConnection$2; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection)>(v); specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,org.fusesource.mqtt.client.Callback,boolean)>(v, v, 0); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(0); specialinvoke v.(v); label: return; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; } void handleSessionFailure(java.lang.Throwable) { java.lang.Throwable v; java.lang.Object[] v; org.fusesource.mqtt.client.MQTT v, v, v; long v, v, v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.hawtdispatch.transport.Transport v; byte v, v; boolean v; org.fusesource.hawtdispatch.transport.HeartBeatMonitor v, v; org.fusesource.mqtt.client.Tracer v; org.fusesource.mqtt.client.CallbackConnection$3 v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: java.lang.Throwable; v = v.; if v != 0 goto label; v = v.; v = v.; v = v cmp 0L; if v < 0 goto label; v = v.; v = v.; v = v.; v = v cmp v; if v >= 0 goto label; label: v = v.; v = v.; v = newarray (java.lang.Object)[0]; virtualinvoke v.("Reconnecting transport", v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = v.; v. = null; if v == null goto label; v = new org.fusesource.mqtt.client.CallbackConnection$3; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection)>(v); interfaceinvoke v.(v); goto label; label: virtualinvoke v.(); goto label; label: specialinvoke v.(v); label: return; } void reconnect(org.fusesource.mqtt.client.Callback) { java.util.concurrent.TimeUnit v; org.fusesource.mqtt.client.CallbackConnection$4 v; long v; org.fusesource.hawtdispatch.DispatchQueue v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.Callback; v = v.; v = specialinvoke v.(); v = ; v = new org.fusesource.mqtt.client.CallbackConnection$4; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,org.fusesource.mqtt.client.Callback)>(v, v); interfaceinvoke v.(v, v, v); return; } void createTransport(org.fusesource.mqtt.client.Callback) throws java.lang.Exception { javax.net.ssl.SSLContext v, v, v; org.fusesource.mqtt.client.CallbackConnection v; java.net.URI v, v, v; boolean v, v, v; org.fusesource.hawtdispatch.transport.TcpTransport v, v; org.fusesource.hawtdispatch.DispatchQueue v; org.fusesource.hawtdispatch.transport.SslTransport v; java.lang.Exception v; org.fusesource.mqtt.client.CallbackConnection$5 v; java.lang.Object[] v; java.util.concurrent.ThreadPoolExecutor v; org.fusesource.mqtt.client.MQTT v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.fusesource.mqtt.client.Callback v; int v, v, v, v, v; java.lang.String v, v, v, v; org.fusesource.hawtdispatch.Task v; java.util.concurrent.Executor v, v; org.fusesource.mqtt.codec.MQTTProtocolCodec v; org.fusesource.mqtt.client.Tracer v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.Callback; v = v.; v = v.; v = newarray (java.lang.Object)[0]; virtualinvoke v.("Connecting", v); v = v.; v = v.; v = virtualinvoke v.(); v = "tcp"; v = virtualinvoke v.(v); if v == 0 goto label; v = new org.fusesource.hawtdispatch.transport.TcpTransport; specialinvoke v.()>(); v = v; goto label; label: v = staticinvoke (v); if v == null goto label; v = new org.fusesource.hawtdispatch.transport.SslTransport; specialinvoke v.()>(); v = v.; v = v.; if v != null goto label; v = v.; v = staticinvoke (); v. = v; label: v = v.; v = v.; virtualinvoke v.(v); v = v; goto label; label: v = new java.lang.Exception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unsupported URI scheme \'\u0001\'"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = v.; if v != null goto label; v = v.; v = staticinvoke (); v. = v; label: v = v.; v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = new org.fusesource.mqtt.codec.MQTTProtocolCodec; specialinvoke v.()>(); interfaceinvoke v.(v); v = v instanceof org.fusesource.hawtdispatch.transport.TcpTransport; if v == 0 goto label; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v); label: v = new org.fusesource.mqtt.client.CallbackConnection$5; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,org.fusesource.mqtt.client.Callback,org.fusesource.hawtdispatch.transport.Transport)>(v, v, v); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); return; } public void onSessionEstablished(org.fusesource.hawtdispatch.transport.Transport) { org.fusesource.mqtt.client.MQTT v, v; org.fusesource.mqtt.client.CallbackConnection v; short v, v; org.fusesource.hawtdispatch.transport.Transport v, v, v, v; java.util.concurrent.atomic.AtomicInteger v; int v, v, v; org.fusesource.hawtdispatch.transport.HeartBeatMonitor v, v, v, v, v, v; org.fusesource.mqtt.client.CallbackConnection$7 v; org.fusesource.mqtt.client.CallbackConnection$6 v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.hawtdispatch.transport.Transport; v. = v; v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = v.; interfaceinvoke v.(); label: v = v.; v = new org.fusesource.mqtt.client.CallbackConnection$6; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection)>(v); interfaceinvoke v.(v); v. = 0L; v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = new org.fusesource.hawtdispatch.transport.HeartBeatMonitor; specialinvoke v.()>(); v. = v; v = v.; v = v.; v = virtualinvoke v.(); v = v * 1000; v = v / 2; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; v = new org.fusesource.mqtt.client.CallbackConnection$7; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection)>(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(); label: return; } public org.fusesource.hawtdispatch.transport.Transport transport() { org.fusesource.hawtdispatch.transport.Transport v; org.fusesource.mqtt.client.CallbackConnection v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; return v; } public org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue() { org.fusesource.hawtdispatch.DispatchQueue v; org.fusesource.mqtt.client.CallbackConnection v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; return v; } public void resume() { org.fusesource.hawtdispatch.transport.HeartBeatMonitor v, v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.hawtdispatch.transport.Transport v, v; java.util.concurrent.atomic.AtomicInteger v, v; int v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: return; } public void suspend() { org.fusesource.hawtdispatch.transport.HeartBeatMonitor v, v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.hawtdispatch.transport.Transport v, v; java.util.concurrent.atomic.AtomicInteger v, v; int v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 1 goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: return; } public org.fusesource.mqtt.client.CallbackConnection refiller(java.lang.Runnable) { org.fusesource.hawtdispatch.DispatchQueue v; java.lang.Runnable v; org.fusesource.mqtt.client.CallbackConnection v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: java.lang.Runnable; v = v.; interfaceinvoke v.(); v. = v; return v; } public org.fusesource.mqtt.client.CallbackConnection listener(org.fusesource.mqtt.client.Listener) { org.fusesource.mqtt.client.CallbackConnection$8 v; org.fusesource.mqtt.client.CallbackConnection v; boolean v; org.fusesource.mqtt.client.Listener v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.Listener; v = v instanceof org.fusesource.mqtt.client.ExtendedListener; if v == 0 goto label; v. = v; goto label; label: v = new org.fusesource.mqtt.client.CallbackConnection$8; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,org.fusesource.mqtt.client.Listener)>(v, v); v. = v; label: return v; } public boolean full() { org.fusesource.hawtdispatch.transport.Transport v; org.fusesource.hawtdispatch.DispatchQueue v; org.fusesource.mqtt.client.CallbackConnection v; boolean v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); return v; } public java.lang.Throwable failure() { java.lang.Throwable v; org.fusesource.hawtdispatch.DispatchQueue v; org.fusesource.mqtt.client.CallbackConnection v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; interfaceinvoke v.(); v = v.; return v; } public void disconnect(org.fusesource.mqtt.client.Callback) { org.fusesource.mqtt.codec.MQTTFrame v; org.fusesource.mqtt.codec.DISCONNECT v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v; org.fusesource.mqtt.client.CallbackConnection$10 v; short v, v; org.fusesource.hawtdispatch.transport.Transport v; org.fusesource.mqtt.client.CallbackConnection$9 v; org.fusesource.mqtt.client.CallbackConnection$Request v; boolean v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.Callback; v = v.; if v == 0 goto label; if v == null goto label; interfaceinvoke v.(null); label: return; label: v. = 1; v = specialinvoke v.(); v = new org.fusesource.mqtt.client.CallbackConnection$9; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,short,org.fusesource.mqtt.client.Callback)>(v, v, v); v = new org.fusesource.mqtt.client.CallbackConnection$10; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,java.lang.Runnable)>(v, v); v = v.; if v == null goto label; v = new org.fusesource.mqtt.codec.DISCONNECT; specialinvoke v.()>(); v = virtualinvoke v.(); v = new org.fusesource.mqtt.client.CallbackConnection$Request; v = specialinvoke v.(); specialinvoke v.(int,org.fusesource.mqtt.codec.MQTTFrame,org.fusesource.mqtt.client.Callback)>(v, v, v); specialinvoke v.(v); goto label; label: interfaceinvoke v.(null); label: return; } public void kill(org.fusesource.mqtt.client.Callback) { org.fusesource.mqtt.client.CallbackConnection$11 v; org.fusesource.hawtdispatch.transport.Transport v; org.fusesource.hawtdispatch.transport.HeartBeatMonitor v, v; org.fusesource.mqtt.client.CallbackConnection v; boolean v; org.fusesource.mqtt.client.Callback v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.Callback; v = v.; if v == 0 goto label; if v == null goto label; interfaceinvoke v.(null); label: return; label: v. = 1; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = v.; v = new org.fusesource.mqtt.client.CallbackConnection$11; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,org.fusesource.mqtt.client.Callback)>(v, v); interfaceinvoke v.(v); return; } public void publish(java.lang.String, byte[], org.fusesource.mqtt.client.QoS, boolean, org.fusesource.mqtt.client.Callback) { byte[] v; org.fusesource.hawtbuf.Buffer v; org.fusesource.mqtt.client.QoS v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v; org.fusesource.hawtbuf.UTF8Buffer v; java.lang.String v; boolean v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: java.lang.String; v := @parameter: byte[]; v := @parameter: org.fusesource.mqtt.client.QoS; v := @parameter: boolean; v := @parameter: org.fusesource.mqtt.client.Callback; v = staticinvoke (v); v = new org.fusesource.hawtbuf.Buffer; specialinvoke v.(byte[])>(v); virtualinvoke v.(v, v, v, v, v); return; } public void publish(org.fusesource.hawtbuf.UTF8Buffer, org.fusesource.hawtbuf.Buffer, org.fusesource.mqtt.client.QoS, boolean, org.fusesource.mqtt.client.Callback) { java.lang.IllegalStateException v; org.fusesource.hawtdispatch.DispatchQueue v; org.fusesource.hawtbuf.Buffer v; org.fusesource.mqtt.client.QoS v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.codec.PUBLISH v, v, v, v; org.fusesource.mqtt.client.Callback v; org.fusesource.hawtbuf.UTF8Buffer v; boolean v, v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.hawtbuf.UTF8Buffer; v := @parameter: org.fusesource.hawtbuf.Buffer; v := @parameter: org.fusesource.mqtt.client.QoS; v := @parameter: boolean; v := @parameter: org.fusesource.mqtt.client.Callback; v = v.; interfaceinvoke v.(); v = v.; if v == 0 goto label; v = staticinvoke (); interfaceinvoke v.(v); return; label: v = new org.fusesource.mqtt.codec.PUBLISH; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); virtualinvoke v.(v); specialinvoke v.(v, v); return; } public void subscribe(org.fusesource.mqtt.client.Topic[], org.fusesource.mqtt.client.Callback) { org.fusesource.mqtt.codec.SUBSCRIBE v, v; java.lang.IllegalStateException v, v; org.fusesource.hawtdispatch.DispatchQueue v; java.lang.IllegalArgumentException v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v; org.fusesource.mqtt.client.CallbackConnection$12 v; org.fusesource.mqtt.client.ExtendedListener v, v; org.fusesource.mqtt.client.Topic[] v; boolean v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.Topic[]; v := @parameter: org.fusesource.mqtt.client.Callback; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("topics must not be null"); throw v; label: v = v.; interfaceinvoke v.(); v = v.; if v == 0 goto label; v = staticinvoke (); interfaceinvoke v.(v); return; label: v = v.; v = ; if v != v goto label; v = staticinvoke (); interfaceinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.SUBSCRIBE; specialinvoke v.()>(); v = virtualinvoke v.(v); v = new org.fusesource.mqtt.client.CallbackConnection$12; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,org.fusesource.mqtt.client.Callback,org.fusesource.mqtt.client.Topic[])>(v, v, v); specialinvoke v.(v, v); label: return; } public void unsubscribe(org.fusesource.hawtbuf.UTF8Buffer[], org.fusesource.mqtt.client.Callback) { org.fusesource.hawtbuf.UTF8Buffer[] v; java.lang.IllegalStateException v; org.fusesource.hawtdispatch.DispatchQueue v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v; org.fusesource.mqtt.client.CallbackConnection$13 v; org.fusesource.mqtt.codec.UNSUBSCRIBE v, v; boolean v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.hawtbuf.UTF8Buffer[]; v := @parameter: org.fusesource.mqtt.client.Callback; v = v.; interfaceinvoke v.(); v = v.; if v == 0 goto label; v = staticinvoke (); interfaceinvoke v.(v); return; label: v = new org.fusesource.mqtt.codec.UNSUBSCRIBE; specialinvoke v.()>(); v = virtualinvoke v.(v); v = new org.fusesource.mqtt.client.CallbackConnection$13; specialinvoke v.(org.fusesource.mqtt.client.CallbackConnection,org.fusesource.mqtt.client.Callback,org.fusesource.hawtbuf.UTF8Buffer[])>(v, v, v); specialinvoke v.(v, v); return; } private void send(org.fusesource.mqtt.codec.MessageSupport$Acked, org.fusesource.mqtt.client.Callback) { org.fusesource.mqtt.codec.MQTTFrame v; org.fusesource.mqtt.codec.MessageSupport$Acked v; org.fusesource.mqtt.client.QoS v, v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v; short v; org.fusesource.mqtt.client.CallbackConnection$Request v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.codec.MessageSupport$Acked; v := @parameter: org.fusesource.mqtt.client.Callback; v = 0; v = interfaceinvoke v.(); v = ; if v == v goto label; v = specialinvoke v.(); interfaceinvoke v.(v); label: v = new org.fusesource.mqtt.client.CallbackConnection$Request; v = interfaceinvoke v.(); specialinvoke v.(int,org.fusesource.mqtt.codec.MQTTFrame,org.fusesource.mqtt.client.Callback)>(v, v, v); specialinvoke v.(v); return; } private void send(org.fusesource.mqtt.client.CallbackConnection$Request) { java.lang.Throwable v, v; org.fusesource.mqtt.client.MQTT v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v, v, v, v; short v, v, v, v; org.fusesource.hawtdispatch.transport.Transport v, v; java.lang.Short v, v; java.util.Map v, v; java.util.LinkedList v, v; boolean v, v; org.fusesource.mqtt.codec.MQTTFrame v, v; org.fusesource.mqtt.client.Tracer v; org.fusesource.mqtt.client.CallbackConnection$Request v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.client.CallbackConnection$Request; v = v.; if v == null goto label; v = v.; if v == null goto label; v = v.; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; if v == 0 goto label; v = v.; v = v.; v = staticinvoke (v); interfaceinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = v.; v = v.; virtualinvoke v.(v); v = v.; if v != 0 goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(null); goto label; label: v = v.; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); v = v.; virtualinvoke v.(v); label: return; } private short getNextMessageId() { java.lang.Throwable v; short v, v, v; int v; java.lang.Object v; org.fusesource.mqtt.client.CallbackConnection v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; entermonitor v; label: v = v.; v = v.; v = v + 1; v. = v; v = v.; if v != 0 goto label; v. = 1; label: exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } private void drainOverflow() { java.lang.Throwable v; org.fusesource.mqtt.client.MQTT v; java.lang.Runnable v, v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v, v; short v, v; org.fusesource.hawtdispatch.transport.Transport v, v; java.lang.Thread$UncaughtExceptionHandler v; java.lang.Short v; java.lang.Thread v, v; java.util.Map v; java.util.LinkedList v, v, v, v; boolean v, v, v; org.fusesource.mqtt.codec.MQTTFrame v, v; org.fusesource.mqtt.client.Tracer v; org.fusesource.hawtdispatch.DispatchQueue v; java.lang.Object v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v = v.; interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v != null goto label; label: return; label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = v.; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; if v != 0 goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(null); goto label; label: v = v.; v = v.; v = staticinvoke (v); interfaceinvoke v.(v, v); goto label; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; if v == null goto label; label: v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (); interfaceinvoke v.(v, v); label: return; catch java.lang.Throwable from label to label with label; } private void completeRequest(short, byte, java.lang.Object) { java.lang.AssertionError v; org.fusesource.mqtt.client.CallbackConnection v; org.fusesource.mqtt.client.Callback v, v, v; short v; byte v, v; java.lang.Short v; java.util.Map v; java.lang.String v; boolean v; org.fusesource.mqtt.codec.MQTTFrame v; java.net.ProtocolException v; java.lang.Object v, v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: short; v := @parameter: byte; v := @parameter: java.lang.Object; v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); if v == null goto label; v = ; if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == v goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = v.; if v == null goto label; if v != null goto label; v = v.; interfaceinvoke v.(null); goto label; label: v = v.; interfaceinvoke v.(v); goto label; label: v = new java.net.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Command from server contained an invalid message id: \u0001"); specialinvoke v.(java.lang.String)>(v); specialinvoke v.(v); label: return; } private void processFrame(org.fusesource.mqtt.codec.MQTTFrame) { byte[] v; org.fusesource.mqtt.client.CallbackConnection v; byte v, v; java.lang.Short v; org.fusesource.mqtt.codec.PUBCOMP v, v, v; org.fusesource.mqtt.codec.PUBREL v, v, v; org.fusesource.mqtt.codec.PUBLISH v, v; org.fusesource.mqtt.codec.PUBREC v, v; org.fusesource.mqtt.codec.PUBACK v, v; org.fusesource.mqtt.codec.SUBACK v, v; org.fusesource.mqtt.client.CallbackConnection$Request v, v; java.lang.Throwable v; java.util.HashMap v; short v, v, v, v, v, v, v; java.lang.String v; org.fusesource.mqtt.codec.MQTTFrame v, v, v; org.fusesource.mqtt.codec.UNSUBACK v, v; java.net.ProtocolException v; java.lang.Object v; v := @this: org.fusesource.mqtt.client.CallbackConnection; v := @parameter: org.fusesource.mqtt.codec.MQTTFrame; label: v = virtualinvoke v.(); tableswitch(v) { case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; case 10: goto label; case 11: goto label; case 12: goto label; case 13: goto label; default: goto label; }; label: v = new org.fusesource.mqtt.codec.PUBLISH; specialinvoke v.()>(); v = virtualinvoke v.(v); specialinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.PUBREL; specialinvoke v.()>(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v = new org.fusesource.mqtt.codec.PUBCOMP; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = new org.fusesource.mqtt.client.CallbackConnection$Request; v = virtualinvoke v.(); specialinvoke v.(int,org.fusesource.mqtt.codec.MQTTFrame,org.fusesource.mqtt.client.Callback)>(0, v, null); specialinvoke v.(v); if v == null goto label; interfaceinvoke v.(null); goto label; label: v = new org.fusesource.mqtt.codec.PUBACK; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v, 3, null); goto label; label: v = new org.fusesource.mqtt.codec.PUBREC; specialinvoke v.()>(); v = virtualinvoke v.(v); v = new org.fusesource.mqtt.codec.PUBREL; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = new org.fusesource.mqtt.client.CallbackConnection$Request; v = virtualinvoke v.(); specialinvoke v.(int,org.fusesource.mqtt.codec.MQTTFrame,org.fusesource.mqtt.client.Callback)>(0, v, null); specialinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.PUBCOMP; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v, 3, null); goto label; label: v = new org.fusesource.mqtt.codec.SUBACK; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.