public class org.apache.activemq.transport.mqtt.MQTTProtocolConverter extends java.lang.Object { private static final org.slf4j.Logger LOG; public static final java.lang.String QOS_PROPERTY_NAME; public static final int V3_1; public static final int V3_1_1; public static final java.lang.String SINGLE_LEVEL_WILDCARD; public static final java.lang.String MULTI_LEVEL_WILDCARD; private static final org.apache.activemq.util.IdGenerator CONNECTION_ID_GENERATOR; private static final org.fusesource.mqtt.codec.MQTTFrame PING_RESP_FRAME; private static final double MQTT_KEEP_ALIVE_GRACE_PERIOD; static final int DEFAULT_CACHE_SIZE; private final org.apache.activemq.command.ConnectionId connectionId; private final org.apache.activemq.command.SessionId sessionId; private final org.apache.activemq.command.ProducerId producerId; private final org.apache.activemq.util.LongSequenceGenerator publisherIdGenerator; private final java.util.concurrent.ConcurrentMap resposeHandlers; private final java.util.Map activeMQDestinationMap; private final java.util.Map mqttTopicMap; private final java.util.Map consumerAcks; private final java.util.Map publisherRecs; private final org.apache.activemq.transport.mqtt.MQTTTransport mqttTransport; private final org.apache.activemq.broker.BrokerService brokerService; private final java.lang.Object commnadIdMutex; private int lastCommandId; private final java.util.concurrent.atomic.AtomicBoolean connected; private final org.apache.activemq.command.ConnectionInfo connectionInfo; private org.fusesource.mqtt.codec.CONNECT connect; private java.lang.String clientId; private long defaultKeepAlive; private int activeMQSubscriptionPrefetch; private final org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator packetIdGenerator; private boolean publishDollarTopics; public int version; private final org.apache.activemq.util.FactoryFinder STRATAGY_FINDER; private java.lang.String subscriptionStrategyName; private org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy subsciptionStrategy; java.util.concurrent.atomic.AtomicBoolean transportErrorHandled; public void (org.apache.activemq.transport.mqtt.MQTTTransport, org.apache.activemq.broker.BrokerService) { java.util.concurrent.atomic.AtomicBoolean v, v; org.apache.activemq.command.ConnectionInfo v; int v; org.apache.activemq.util.FactoryFinder v; java.lang.String v; org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; org.apache.activemq.util.LRUCache v, v, v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.ConnectionId v, v; org.apache.activemq.command.SessionId v, v; java.util.concurrent.ConcurrentHashMap v; org.apache.activemq.command.ProducerId v; org.apache.activemq.transport.mqtt.MQTTTransport v; org.apache.activemq.util.LongSequenceGenerator v; java.lang.Object v; org.apache.activemq.util.IdGenerator v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.apache.activemq.transport.mqtt.MQTTTransport; v := @parameter: org.apache.activemq.broker.BrokerService; specialinvoke v.()>(); v = new org.apache.activemq.command.ConnectionId; v = ; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v. = v; v = new org.apache.activemq.command.SessionId; v = v.; specialinvoke v.(org.apache.activemq.command.ConnectionId,long)>(v, -1L); v. = v; v = new org.apache.activemq.command.ProducerId; v = v.; specialinvoke v.(org.apache.activemq.command.SessionId,long)>(v, 1L); v. = v; v = new org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.util.LRUCache; specialinvoke v.(int)>(5000); v. = v; v = new org.apache.activemq.util.LRUCache; specialinvoke v.(int)>(5000); v. = v; v = new org.apache.activemq.util.LRUCache; specialinvoke v.(int)>(5000); v. = v; v = new org.apache.activemq.util.LRUCache; specialinvoke v.(int)>(5000); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new org.apache.activemq.command.ConnectionInfo; specialinvoke v.()>(); v. = v; v = (int) -1; v. = v; v = new org.apache.activemq.util.FactoryFinder; specialinvoke v.(java.lang.String)>("META-INF/services/org/apache/activemq/transport/strategies/"); v. = v; v. = "mqtt-default-subscriptions"; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v. = v; v. = v; v = staticinvoke (v); v. = v; v. = 0L; return; } int generateCommandId() { java.lang.Throwable v; int v, v; java.lang.Object v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v = v.; entermonitor v; label: v = v.; v = v + 1; v. = v; exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } public void sendToActiveMQ(org.apache.activemq.command.Command, org.apache.activemq.transport.mqtt.ResponseHandler) { org.apache.activemq.command.Response v; java.lang.Integer v; java.util.concurrent.ConcurrentMap v; int v, v; java.lang.String v, v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; boolean v, v, v; org.slf4j.Logger v, v; org.apache.activemq.command.Command v; java.io.IOException v, v; org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.transport.mqtt.MQTTTransport v; org.apache.activemq.transport.mqtt.ResponseHandler v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.apache.activemq.command.Command; v := @parameter: org.apache.activemq.transport.mqtt.ResponseHandler; v = v instanceof org.apache.activemq.command.ActiveMQMessage; if v == 0 goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; if v == null goto label; label: v = new org.apache.activemq.command.Response; specialinvoke v.()>(); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to send command \u0001"); interfaceinvoke v.(v, v); label: return; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to send command \u0001"); interfaceinvoke v.(v, v); label: v = virtualinvoke v.(); interfaceinvoke v.(v); if v == null goto label; interfaceinvoke v.(1); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); label: v = virtualinvoke v.(); interfaceinvoke v.(v); return; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } void sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame) { org.fusesource.mqtt.codec.MQTTFrame v; org.apache.activemq.transport.mqtt.MQTTTransport v; org.slf4j.Logger v; java.io.IOException v; java.lang.String v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.MQTTFrame; label: v = v.; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to send frame \u0001"); interfaceinvoke v.(v, v); label: return; catch java.io.IOException from label to label with label; } public void onMQTTCommand(org.fusesource.mqtt.codec.MQTTFrame) throws java.io.IOException, javax.jms.JMSException { java.lang.Integer v; byte v, v; org.fusesource.mqtt.codec.PUBCOMP v, v; org.fusesource.mqtt.codec.PUBREL v, v; org.fusesource.mqtt.codec.PUBLISH v, v; org.fusesource.mqtt.codec.PUBREC v, v; org.fusesource.mqtt.codec.PUBACK v, v; org.apache.activemq.transport.mqtt.MQTTProtocolException v; org.fusesource.mqtt.codec.CONNECT v, v; org.fusesource.mqtt.codec.UNSUBSCRIBE v, v; int v; java.lang.String v, v, v, v, v, v, v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; org.fusesource.mqtt.codec.MQTTFrame v, v; org.fusesource.mqtt.codec.SUBSCRIBE v, v; org.slf4j.Logger v, v, v, v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.MQTTFrame; v = virtualinvoke v.(); tableswitch(v) { case 1: goto label; case 2: goto label; 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; case 14: goto label; default: goto label; }; label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Received a ping from client: \u0001"); interfaceinvoke v.(v); virtualinvoke v.(); v = ; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Sent Ping Response to \u0001"); interfaceinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.CONNECT; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("MQTT Client {} connected. (version: {})", v, v); goto label; label: v = ; v = virtualinvoke v.(); interfaceinvoke v.("MQTT Client {} disconnecting", v); virtualinvoke v.(); goto label; label: v = new org.fusesource.mqtt.codec.SUBSCRIBE; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.UNSUBSCRIBE; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.PUBLISH; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.PUBACK; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.PUBREC; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.PUBREL; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = new org.fusesource.mqtt.codec.PUBCOMP; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = new org.apache.activemq.transport.mqtt.MQTTProtocolException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown MQTTFrame type: \u0001"); specialinvoke v.(java.lang.String,boolean)>(v, 1); virtualinvoke v.(v, v); label: return; } void onMQTTConnect(org.fusesource.mqtt.codec.CONNECT) throws org.apache.activemq.transport.mqtt.MQTTProtocolException { org.fusesource.mqtt.codec.CONNACK$Code v, v; boolean v, v, v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter$1 v; org.apache.activemq.transport.mqtt.MQTTTransport v, v, v, v, v, v, v, v; java.security.cert.X509Certificate[] v; org.apache.activemq.transport.mqtt.MQTTProtocolException v; org.fusesource.mqtt.codec.CONNECT v; java.util.concurrent.atomic.AtomicBoolean v; short v; org.apache.activemq.command.ConnectionInfo v, v, v, v, v, v, v, v, v; org.fusesource.mqtt.codec.CONNACK v, v; int v, v, v, v; java.lang.String v, v, v, v, v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; org.fusesource.mqtt.codec.MQTTFrame v, v; org.apache.activemq.command.ConnectionId v, v; java.io.IOException v, v, v, v, v, v, v; org.fusesource.hawtbuf.UTF8Buffer v, v, v, v, v, v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.CONNECT; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.transport.mqtt.MQTTProtocolException; specialinvoke v.(java.lang.String)>("Already connected."); throw v; label: v. = v; v = virtualinvoke v.(); if v < 3 goto label; v = virtualinvoke v.(); if v <= 4 goto label; label: v = new org.fusesource.mqtt.codec.CONNACK; specialinvoke v.()>(); v = ; virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke ("Unsupported or invalid protocol version", null); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: return; label: v = ""; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); label: v = null; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); label: v = null; v = virtualinvoke v.(); if v == null goto label; if v != null goto label; v = virtualinvoke v.(); if v == 3 goto label; v = virtualinvoke v.(); v = staticinvoke ("Password given without a user name", null); interfaceinvoke v.(v); return; label: v = virtualinvoke v.(); v = virtualinvoke v.(); label: v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = new org.fusesource.mqtt.codec.CONNACK; specialinvoke v.()>(); v = ; virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke ("Invalid Client ID", null); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: return; label: v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001"); virtualinvoke v.(v); label: v = v.; virtualinvoke v.(1); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v); v = v.; v = new org.apache.activemq.transport.mqtt.MQTTProtocolConverter$1; specialinvoke v.(org.apache.activemq.transport.mqtt.MQTTProtocolConverter,org.fusesource.mqtt.codec.CONNECT)>(v, v); virtualinvoke v.(v, v); return; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } void onMQTTDisconnect() throws org.apache.activemq.transport.mqtt.MQTTProtocolException { org.apache.activemq.command.ConnectionInfo v; org.apache.activemq.command.ShutdownInfo v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; org.apache.activemq.command.RemoveInfo v; boolean v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v = v.; v = virtualinvoke v.(1, 0); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, null); v = new org.apache.activemq.command.ShutdownInfo; specialinvoke v.()>(); virtualinvoke v.(v, null); label: specialinvoke v.(); return; } void onSubscribe(org.fusesource.mqtt.codec.SUBSCRIBE) throws org.apache.activemq.transport.mqtt.MQTTProtocolException { byte[] v; org.fusesource.mqtt.client.Topic v, v; byte v; java.lang.Short v; org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy v; org.apache.activemq.transport.mqtt.MQTTTransport v; org.fusesource.mqtt.codec.SUBACK v; java.lang.Object[] v; org.apache.activemq.transport.mqtt.MQTTProtocolException v, v; short v, v; org.apache.activemq.command.ConnectionInfo v; int v, v, v; java.lang.String v, v, v, v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; org.fusesource.mqtt.codec.MQTTFrame v; org.fusesource.mqtt.codec.SUBSCRIBE v; org.slf4j.Logger v, v, v; org.apache.activemq.command.ConnectionId v; java.io.IOException v, v; org.fusesource.hawtbuf.UTF8Buffer v; org.fusesource.mqtt.client.Topic[] v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.SUBSCRIBE; virtualinvoke v.(); v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v[1] = v; v = v.; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("MQTT SUBSCRIBE message:{} client:{} connection:{}", v); v = virtualinvoke v.(); if v == null goto label; v = lengthof v; v = newarray (byte)[v]; v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = virtualinvoke v.(); v = v[v]; v = interfaceinvoke v.(v); v[v] = v; label: goto label; label: v := @caughtexception; v = new org.apache.activemq.transport.mqtt.MQTTProtocolException; specialinvoke v.(java.lang.String,boolean,java.lang.Throwable)>("Failed to process subscription request", 1, v); throw v; label: v = v + 1; goto label; label: v = new org.fusesource.mqtt.codec.SUBACK; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Couldn\'t send SUBACK for \u0001"); interfaceinvoke v.(v, v); goto label; label: v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("No topics defined for Subscription \u0001"); interfaceinvoke v.(v); v = new org.apache.activemq.transport.mqtt.MQTTProtocolException; specialinvoke v.(java.lang.String)>("SUBSCRIBE command received with no topic filter"); throw v; label: return; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } public void onUnSubscribe(org.fusesource.mqtt.codec.UNSUBSCRIBE) throws org.apache.activemq.transport.mqtt.MQTTProtocolException { org.apache.activemq.transport.mqtt.MQTTProtocolException v, v, v; org.fusesource.mqtt.client.QoS v, v; short v; org.fusesource.mqtt.codec.UNSUBSCRIBE v; int v, v, v; java.lang.String v, v, v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; boolean v; org.fusesource.hawtbuf.UTF8Buffer[] v; org.fusesource.mqtt.codec.MQTTFrame v; org.slf4j.Logger v; org.fusesource.mqtt.codec.UNSUBACK v; java.io.IOException v; java.lang.Exception v; org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy v; org.fusesource.hawtbuf.UTF8Buffer v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.UNSUBSCRIBE; virtualinvoke v.(); v = virtualinvoke v.(); v = ; if v == v goto label; v = v.; if v != 3 goto label; v = v.; if v == 1 goto label; label: v = new org.apache.activemq.transport.mqtt.MQTTProtocolException; v = new java.lang.Exception; specialinvoke v.(java.lang.String)>("UNSUBSCRIBE frame not properly formatted, QoS"); specialinvoke v.(java.lang.String,boolean,java.lang.Throwable)>("Failed to process unsubscribe request", 1, v); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); staticinvoke (v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.activemq.transport.mqtt.MQTTProtocolException; specialinvoke v.(java.lang.String,boolean,java.lang.Throwable)>("Failed to process unsubscribe request", 1, v); throw v; label: v = v + 1; goto label; label: v = new org.fusesource.mqtt.codec.UNSUBACK; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("No topics defined for Subscription \u0001"); interfaceinvoke v.(v); v = new org.apache.activemq.transport.mqtt.MQTTProtocolException; specialinvoke v.(java.lang.String)>("UNSUBSCRIBE command received with no topic filter"); throw v; label: return; catch java.io.IOException from label to label with label; } public void onActiveMQCommand(org.apache.activemq.command.Command) throws java.lang.Exception { java.lang.Integer v; org.apache.activemq.command.ConsumerId v; org.fusesource.mqtt.client.QoS v; org.apache.activemq.command.Message v, v; byte v; int[] v; java.lang.Short v, v; java.util.Map v, v; boolean v, v, v, v, v, v, v, v; org.apache.activemq.transport.mqtt.MQTTSubscription v; org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy v; org.fusesource.mqtt.codec.PUBLISH v; org.apache.activemq.transport.mqtt.MQTTTransport v, v; java.lang.Throwable v, v, v; org.apache.activemq.command.Response v; java.lang.Object[] v; java.util.concurrent.ConcurrentMap v; short v, v; org.apache.activemq.command.ConnectionInfo v; int v, v, v; java.lang.String v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; org.fusesource.mqtt.codec.MQTTFrame v; org.apache.activemq.command.MessageAck v; org.slf4j.Logger v, v; org.apache.activemq.command.Command v; org.apache.activemq.command.ConnectionId v; java.lang.Object v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.apache.activemq.command.Command; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v == null goto label; interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v, null); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); label: virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v[1] = v; v = v.; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("MQTT Snd PUBLISH message:{} client:{} connection:{}", v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v != 16 goto label; v = virtualinvoke v.(); virtualinvoke v.(v, null); goto label; label: v = interfaceinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("Do not know how to process ActiveMQ Command {}", v); label: return; catch java.lang.Throwable from label to label with label; } void onMQTTPublish(org.fusesource.mqtt.codec.PUBLISH) throws java.io.IOException, javax.jms.JMSException { java.lang.Object[] v; org.apache.activemq.command.ActiveMQMessage v; short v; org.apache.activemq.command.ConnectionInfo v; java.lang.Short v; java.lang.String v, v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; boolean v; org.slf4j.Logger v; org.apache.activemq.command.ConnectionId v; java.io.IOException v; org.fusesource.mqtt.codec.PUBLISH v; org.apache.activemq.command.ProducerId v; org.apache.activemq.transport.mqtt.MQTTTransport v; org.apache.activemq.transport.mqtt.ResponseHandler v; org.fusesource.hawtbuf.UTF8Buffer v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.PUBLISH; virtualinvoke v.(); v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v[1] = v; v = v.; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("MQTT Rcv PUBLISH message:{} client:{} connection:{}", v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke ("The topic name must not contain wildcard characters.", null); interfaceinvoke v.(v); return; label: v = virtualinvoke v.(v); v = v.; virtualinvoke v.(v); virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v, v); return; } void onMQTTPubAck(org.fusesource.mqtt.codec.PUBACK) { java.lang.Throwable v; java.lang.Object[] v; short v; org.apache.activemq.command.ConnectionInfo v; java.lang.Short v, v; java.util.Map v, v; java.lang.String v, v; org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; org.slf4j.Logger v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.transport.mqtt.MQTTTransport v; org.fusesource.mqtt.codec.PUBACK v; java.lang.Object v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.PUBACK; v = virtualinvoke v.(); v = ; v = newarray (java.lang.Object)[3]; v = staticinvoke (v); v[0] = v; v = v.; v[1] = v; v = v.; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("MQTT Rcv PUBACK message:{} client:{} connection:{}", v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v.; entermonitor v; label: v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } void onMQTTPubRec(org.fusesource.mqtt.codec.PUBREC) { org.fusesource.mqtt.codec.MQTTFrame v; org.fusesource.mqtt.codec.PUBREC v; short v; org.fusesource.mqtt.codec.PUBREL v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.PUBREC; v = new org.fusesource.mqtt.codec.PUBREL; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); return; } void onMQTTPubRel(org.fusesource.mqtt.codec.PUBREL) { java.lang.Throwable v; org.fusesource.mqtt.codec.MQTTFrame v; org.slf4j.Logger v; org.fusesource.mqtt.codec.PUBCOMP v; org.fusesource.mqtt.codec.PUBREL v; short v, v, v; java.lang.Short v, v; java.util.Map v, v; java.lang.Object v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.PUBREL; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v != null goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Unknown PUBREL: {} received", v); label: v = new org.fusesource.mqtt.codec.PUBCOMP; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); return; catch java.lang.Throwable from label to label with label; } void onMQTTPubComp(org.fusesource.mqtt.codec.PUBCOMP) { java.lang.Throwable v; org.fusesource.mqtt.codec.PUBCOMP v; org.apache.activemq.transport.mqtt.MQTTTransport v; short v; java.lang.Short v; java.util.Map v, v; java.lang.Object v; java.lang.String v; org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.PUBCOMP; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v.; entermonitor v; label: v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } org.apache.activemq.command.ActiveMQMessage convertMessage(org.fusesource.mqtt.codec.PUBLISH) throws javax.jms.JMSException { byte[] v; org.fusesource.mqtt.client.QoS v, v, v; java.lang.Short v; java.util.Map v, v, v; boolean v, v; org.apache.activemq.command.MessageId v, v; javax.jms.JMSException v; org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy v; org.fusesource.mqtt.codec.PUBLISH v; org.apache.activemq.util.LongSequenceGenerator v; java.lang.Throwable v; org.apache.activemq.command.ActiveMQBytesMessage v; java.lang.Object[] v; long v, v; org.fusesource.hawtbuf.Buffer v, v, v; short v; org.apache.activemq.command.ConnectionInfo v; int v, v, v; java.lang.String v, v, v, v, v; org.apache.activemq.transport.mqtt.MQTTProtocolConverter v; org.slf4j.Logger v; org.apache.activemq.command.ConnectionId v; java.io.IOException v; org.apache.activemq.command.ProducerId v, v; org.fusesource.hawtbuf.UTF8Buffer v, v, v; java.lang.Object v; v := @this: org.apache.activemq.transport.mqtt.MQTTProtocolConverter; v := @parameter: org.fusesource.mqtt.codec.PUBLISH; v = new org.apache.activemq.command.ActiveMQBytesMessage; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); v = new org.apache.activemq.command.MessageId; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.ProducerId,long)>(v, v); virtualinvoke v.(v); v = ; v = newarray (java.lang.Object)[4]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v[1] = v; v = v.; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; interfaceinvoke v.("MQTT-->ActiveMQ: MQTT_MSGID:{} client:{} connection:{} ActiveMQ_MSGID:{}", v); v = staticinvoke (); virtualinvoke v.(v); virtualinvoke v.(4); v = virtualinvoke v.(); v = ; if v == v goto label; v = 1; goto label; label: v = 0; label: virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("ActiveMQ.MQTT.QoS", v); v = virtualinvoke v.