public class org.apache.activemq.transport.stomp.ProtocolConverter extends java.lang.Object { private static final org.slf4j.Logger LOG; private static final org.apache.activemq.util.IdGenerator CONNECTION_ID_GENERATOR; private static final java.lang.String BROKER_VERSION; private static final org.apache.activemq.transport.stomp.StompFrame ping; 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 consumerIdGenerator; private final org.apache.activemq.util.LongSequenceGenerator messageIdGenerator; private final org.apache.activemq.util.LongSequenceGenerator transactionIdGenerator; private final org.apache.activemq.util.LongSequenceGenerator tempDestinationGenerator; private final java.util.concurrent.ConcurrentMap resposeHandlers; private final java.util.concurrent.ConcurrentMap subscriptionsByConsumerId; private final java.util.concurrent.ConcurrentMap subscriptions; private final java.util.concurrent.ConcurrentMap tempDestinations; private final java.util.concurrent.ConcurrentMap tempDestinationAmqToStompMap; private final java.util.Map transactions; private final org.apache.activemq.transport.stomp.StompTransport stompTransport; private final java.util.concurrent.ConcurrentMap pendingAcksTracker; private final java.util.Map pendingAcks; private final java.lang.Object commnadIdMutex; private int lastCommandId; private final java.util.concurrent.atomic.AtomicBoolean connected; private final org.apache.activemq.transport.stomp.FrameTranslator frameTranslator; private java.util.concurrent.ConcurrentMap jmsFrameTranslators; private final org.apache.activemq.util.FactoryFinder FRAME_TRANSLATOR_FINDER; private final org.apache.activemq.broker.BrokerContext brokerContext; private java.lang.String version; private long hbReadInterval; private long hbWriteInterval; private float hbGracePeriodMultiplier; private java.lang.String defaultHeartBeat; org.apache.activemq.command.ConnectionInfo connectionInfo; public void (org.apache.activemq.transport.stomp.StompTransport, org.apache.activemq.broker.BrokerContext) { java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.transport.stomp.LegacyFrameTranslator v; org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ConnectionInfo v; java.util.Map v; org.apache.activemq.util.FactoryFinder v; java.lang.String v; org.apache.activemq.transport.stomp.StompTransport v; org.apache.activemq.command.ConnectionId v, v; org.apache.activemq.command.SessionId v, v; java.util.concurrent.ConcurrentHashMap v, v, v, v, v, v, v, v; org.apache.activemq.broker.BrokerContext v; org.apache.activemq.command.ProducerId v; org.apache.activemq.util.LongSequenceGenerator v, v, v, v; java.lang.Object v; org.apache.activemq.util.IdGenerator v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompTransport; v := @parameter: org.apache.activemq.broker.BrokerContext; 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 org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); 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 java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = v.; v = staticinvoke (v); 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.transport.stomp.LegacyFrameTranslator; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.util.FactoryFinder; specialinvoke v.(java.lang.String)>("META-INF/services/org/apache/activemq/transport/frametranslator/"); v. = v; v. = "1.0"; v. = 1.0F; v. = "0,0"; v = new org.apache.activemq.command.ConnectionInfo; specialinvoke v.()>(); v. = v; v. = v; v. = v; return; } protected int generateCommandId() { java.lang.Throwable v; int v, v; java.lang.Object v; org.apache.activemq.transport.stomp.ProtocolConverter v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; 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; } protected org.apache.activemq.transport.stomp.ResponseHandler createResponseHandler(org.apache.activemq.transport.stomp.StompFrame) { org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.transport.stomp.ProtocolConverter$1 v; java.util.Map v; java.lang.Object v; org.apache.activemq.transport.stomp.ProtocolConverter v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; v = virtualinvoke v.(); v = interfaceinvoke v.("receipt"); if v == null goto label; v = new org.apache.activemq.transport.stomp.ProtocolConverter$1; specialinvoke v.(org.apache.activemq.transport.stomp.ProtocolConverter,org.apache.activemq.transport.stomp.StompFrame,java.lang.String)>(v, v, v); return v; label: return null; } protected void sendToActiveMQ(org.apache.activemq.command.Command, org.apache.activemq.transport.stomp.ResponseHandler) { org.apache.activemq.transport.stomp.StompTransport v; org.apache.activemq.command.Command v; java.lang.Integer v; org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.concurrent.ConcurrentMap v; int v, v; org.apache.activemq.transport.stomp.ResponseHandler v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.command.Command; v := @parameter: org.apache.activemq.transport.stomp.ResponseHandler; 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 = v.; interfaceinvoke v.(v); return; } protected void sendToStomp(org.apache.activemq.transport.stomp.StompFrame) throws java.io.IOException { org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.transport.stomp.StompTransport v; org.apache.activemq.transport.stomp.ProtocolConverter v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; v = v.; interfaceinvoke v.(v); return; } protected org.apache.activemq.transport.stomp.FrameTranslator findTranslator(java.lang.String) { java.lang.String v; org.apache.activemq.transport.stomp.FrameTranslator v; org.apache.activemq.transport.stomp.ProtocolConverter v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: java.lang.String; v = virtualinvoke v.(v, null, 0); return v; } protected org.apache.activemq.transport.stomp.FrameTranslator findTranslator(java.lang.String, org.apache.activemq.command.ActiveMQDestination, boolean) { org.apache.activemq.transport.stomp.JmsFrameTranslator v; org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.util.FactoryFinder v; java.lang.String v, v, v; boolean v, v, v; org.slf4j.Logger v, v, v; org.apache.activemq.broker.BrokerContext v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v; java.lang.Object v; org.apache.activemq.transport.stomp.FrameTranslator v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: boolean; v = v.; label: if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Creating a new FrameTranslator to convert \u0001"); interfaceinvoke v.(v); v = v.; virtualinvoke v.(v); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed in creating FrameTranslator to convert \u0001"); interfaceinvoke v.(v); goto label; label: if v == null goto label; if v != 0 goto label; v = staticinvoke (v); if v == 0 goto label; label: v = new org.apache.activemq.transport.stomp.JmsFrameTranslator; specialinvoke v.()>(); v = v; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed in getting a FrameTranslator to convert ", v); v = v.; label: v = v instanceof org.apache.activemq.broker.BrokerContextAware; if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: return v; catch java.lang.Exception from label to label with label; } public void onStompCommand(org.apache.activemq.transport.stomp.StompFrame) throws java.io.IOException, javax.jms.JMSException { org.apache.activemq.transport.stomp.ProtocolConverter v; java.lang.String v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.transport.stomp.StompTransport v; org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.transport.stomp.ProtocolException v, v, v; java.lang.Class v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; label: v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/transport/stomp/StompFrameError;" goto label; v = virtualinvoke v.(); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.("SEND"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("ACK"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("NACK"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("BEGIN"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("COMMIT"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("ABORT"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("SUB"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("UNSUB"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("CONNECT"); if v != 0 goto label; v = virtualinvoke v.("STOMP"); if v == 0 goto label; label: virtualinvoke v.(v); goto label; label: v = virtualinvoke v.("DISCONNECT"); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown STOMP action: \u0001"); specialinvoke v.(java.lang.String,boolean)>(v, 1); throw v; label: v := @caughtexception; virtualinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; catch org.apache.activemq.transport.stomp.ProtocolException from label to label with label; } protected void handleException(java.lang.Throwable, org.apache.activemq.transport.stomp.StompFrame) throws java.io.IOException { org.apache.activemq.util.ByteArrayOutputStream v; byte[] v; java.util.Map v; boolean v, v, v, v, v; java.io.PrintWriter v; java.lang.Exception v, v; org.apache.activemq.transport.stomp.StompFrame v, v; java.lang.Throwable v, v; java.lang.Object[] v, v, v; java.util.HashMap v; org.apache.activemq.transport.stomp.ProtocolConverter v; org.apache.activemq.command.ConnectionInfo v, v, v, v, v, v; java.io.OutputStreamWriter v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: java.lang.Throwable; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Exception occurred while processing a command: {}", v); goto label; label: v = v instanceof javax.jms.JMSException; if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = ; v = newarray (java.lang.Object)[5]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[4] = v; interfaceinvoke v.("Exception occurred for client {} ({}) processing: {} -> {} ({})", v); goto label; label: v = ; v = newarray (java.lang.Object)[4]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v[2] = v; v = virtualinvoke v.(); v[3] = v; interfaceinvoke v.("Exception occurred for client {} ({}) processing: {} -> {}", v); goto label; label: v = ; v = newarray (java.lang.Object)[4]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v[2] = v; v = virtualinvoke v.(); v[3] = v; interfaceinvoke v.("Exception occurred for client {} ({}) processing: {} -> {}", v); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Exception detail", v); label: if v == null goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Command that caused the error: {}", v); label: v = new org.apache.activemq.util.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.PrintWriter; v = new java.io.OutputStreamWriter; specialinvoke v.(java.io.OutputStream,java.lang.String)>(v, "UTF-8"); specialinvoke v.(java.io.Writer)>(v); v = v instanceof java.lang.SecurityException; if v != 0 goto label; v = virtualinvoke v.(); v = v instanceof java.lang.SecurityException; if v == 0 goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.("message", v); virtualinvoke v.("content-type", "text/plain"); if v == null goto label; v = virtualinvoke v.(); v = interfaceinvoke v.("receipt"); if v == null goto label; virtualinvoke v.("receipt-id", v); label: v = new org.apache.activemq.transport.stomp.StompFrame; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.util.Map,byte[])>("ERROR", v, v); virtualinvoke v.(v); return; } protected void onStompSend(org.apache.activemq.transport.stomp.StompFrame) throws java.io.IOException, javax.jms.JMSException { org.apache.activemq.command.ActiveMQMessage v; long v; org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.Map v, v; java.lang.String v; org.apache.activemq.transport.stomp.ResponseHandler v; org.apache.activemq.command.MessageId v; org.apache.activemq.command.ProducerId v, v; org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.util.LongSequenceGenerator v; org.apache.activemq.transport.stomp.ProtocolException v, v; java.lang.Object v, v, v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("destination"); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("SEND received without a Destination specified!"); throw v; label: v = interfaceinvoke v.("transaction"); interfaceinvoke v.("transaction"); v = virtualinvoke v.(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); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid transaction id: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: virtualinvoke v.(v); label: virtualinvoke v.(); virtualinvoke v.(null); v = virtualinvoke v.(v); virtualinvoke v.(v, v); return; } protected void onStompNack(org.apache.activemq.transport.stomp.StompFrame) throws org.apache.activemq.transport.stomp.ProtocolException { java.util.Map v, v, v; org.apache.activemq.transport.stomp.ResponseHandler v, v; boolean v, v, v, v, v; org.apache.activemq.command.MessageId v; org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.concurrent.ConcurrentMap v; java.lang.String v, v, v, v, v, v; org.apache.activemq.command.MessageAck v, v; org.apache.activemq.transport.stomp.ProtocolException v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; virtualinvoke v.(); v = v.; v = virtualinvoke v.("1.0"); if v == 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("NACK received but connection is in v.0 mode."); throw v; label: v = virtualinvoke v.(); v = interfaceinvoke v.("subscription"); if v != null goto label; v = v.; v = virtualinvoke v.("1.2"); if v != 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("NACK received without a subscription id for acknowledge!"); throw v; label: v = interfaceinvoke v.("message-id"); if v != null goto label; v = v.; v = virtualinvoke v.("1.2"); if v != 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("NACK received without a message-id to acknowledge!"); throw v; label: v = interfaceinvoke v.("id"); if v != null goto label; v = v.; v = virtualinvoke v.("1.2"); if v == 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("NACK received without an ack header to acknowledge!"); throw v; label: v = interfaceinvoke v.("transaction"); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid transaction id: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = 0; if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.(v, v); v = 1; goto label; label: if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.(v, v); v = 1; label: if v != 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unexpected NACK received for message-id [\u]"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } protected void onStompAck(org.apache.activemq.transport.stomp.StompFrame) throws org.apache.activemq.transport.stomp.ProtocolException { java.util.Map v, v, v; org.apache.activemq.transport.stomp.ResponseHandler v, v, v; boolean v, v, v, v, v; org.apache.activemq.command.MessageId v; java.util.Collection v; org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.concurrent.ConcurrentMap v, v; java.lang.String v, v, v, v, v; org.apache.activemq.command.MessageAck v, v, v; java.util.Iterator v; org.apache.activemq.transport.stomp.ProtocolException v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("message-id"); if v != null goto label; v = v.; v = virtualinvoke v.("1.2"); if v != 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("ACK received without a message-id to acknowledge!"); throw v; label: v = interfaceinvoke v.("subscription"); if v != null goto label; v = v.; v = virtualinvoke v.("1.1"); if v == 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("ACK received without a subscription id for acknowledge!"); throw v; label: v = interfaceinvoke v.("id"); if v != null goto label; v = v.; v = virtualinvoke v.("1.2"); if v == 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("ACK received without a ack id for acknowledge!"); throw v; label: v = interfaceinvoke v.("transaction"); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid transaction id: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = 0; if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.(v, v); v = 1; goto label; label: if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.(v, v); v = 1; goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.(v, v); v = 1; label: if v != 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unexpected ACK received for message-id [\u]"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } protected void onStompBegin(org.apache.activemq.transport.stomp.StompFrame) throws org.apache.activemq.transport.stomp.ProtocolException { org.apache.activemq.command.LocalTransactionId v; long v; org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.Map v, v, v; java.lang.String v; org.apache.activemq.transport.stomp.ResponseHandler v; boolean v; org.apache.activemq.command.ConnectionId v, v; org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.util.LongSequenceGenerator v; org.apache.activemq.transport.stomp.ProtocolException v, v; java.lang.Object v, v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("transaction"); v = interfaceinvoke v.("transaction"); if v != 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("Must specify the transaction you are beginning"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("The transaction was already started: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.activemq.command.LocalTransactionId; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.ConnectionId,long)>(v, v); v = v.; interfaceinvoke v.(v, v); v = new org.apache.activemq.command.TransactionInfo; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(0); v = virtualinvoke v.(v); virtualinvoke v.(v, v); return; } protected void onStompCommit(org.apache.activemq.transport.stomp.StompFrame) throws org.apache.activemq.transport.stomp.ProtocolException { org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.concurrent.ConcurrentMap v; java.util.Map v, v; java.lang.String v; org.apache.activemq.transport.stomp.ResponseHandler v; boolean v; java.util.Iterator v; org.apache.activemq.command.ConnectionId v; java.util.Collection v; org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.transport.stomp.ProtocolException v, v; java.lang.Object v, v, v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("transaction"); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("Must specify the transaction you are committing"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid transaction id: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = new org.apache.activemq.command.TransactionInfo; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(2); v = virtualinvoke v.(v); virtualinvoke v.(v, v); return; } protected void onStompAbort(org.apache.activemq.transport.stomp.StompFrame) throws org.apache.activemq.transport.stomp.ProtocolException { org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.concurrent.ConcurrentMap v; java.util.Map v, v; java.lang.String v; org.apache.activemq.transport.stomp.ResponseHandler v; boolean v; java.util.Iterator v; org.apache.activemq.command.ConnectionId v; java.util.Collection v; java.lang.Exception v; org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.command.TransactionInfo v; org.apache.activemq.transport.stomp.ProtocolException v, v, v; java.lang.Object v, v, v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("transaction"); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("Must specify the transaction you are committing"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid transaction id: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String,boolean,java.lang.Throwable)>("Transaction abort failed", 0, v); throw v; label: v = new org.apache.activemq.command.TransactionInfo; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(4); v = virtualinvoke v.(v); virtualinvoke v.(v, v); return; catch java.lang.Exception from label to label with label; } protected void onStompSubscribe(org.apache.activemq.transport.stomp.StompFrame) throws org.apache.activemq.transport.stomp.ProtocolException { org.apache.activemq.command.ConsumerId v; java.util.Map v, v, v; org.apache.activemq.transport.stomp.ResponseHandler v; boolean v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.SessionId v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.transport.stomp.StompFrame v; org.apache.activemq.util.LongSequenceGenerator v; long v; org.apache.activemq.transport.stomp.ProtocolConverter v; java.util.concurrent.ConcurrentMap v, v, v, v; short v; int v, v; java.lang.String v, v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v; org.apache.activemq.transport.stomp.StompSubscription v, v; org.apache.activemq.transport.stomp.StompQueueBrowserSubscription v; org.apache.activemq.transport.stomp.ProtocolConverter$2 v; org.apache.activemq.transport.stomp.ProtocolException v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v; org.apache.activemq.transport.stomp.FrameTranslator v; v := @this: org.apache.activemq.transport.stomp.ProtocolConverter; v := @parameter: org.apache.activemq.transport.stomp.StompFrame; virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("transformation"); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.("id"); v = interfaceinvoke v.("destination"); v = v.; v = virtualinvoke v.("1.0"); if v != 0 goto label; if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("SUBSCRIBE received without a subscription id!"); throw v; label: if v == null goto label; v = ""; v = virtualinvoke v.(v); if v == 0 goto label; label: v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("Invalid empty or \'null\' Destination header"); throw v; label: v = interfaceinvoke v.(v, v, 1); if v != null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("Invalid \'null\' Destination."); throw v; label: v = new org.apache.activemq.command.ConsumerId; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.SessionId,long)>(v, v); v = new org.apache.activemq.command.ConsumerInfo; specialinvoke v.(org.apache.activemq.command.ConsumerId)>(v); v = virtualinvoke v.(); if v == 0 goto label; v = 1000; goto label; label: v = interfaceinvoke v.("activemq.subscriptionName"); if v == 0 goto label; v = 100; goto label; label: v = 32767; label: virtualinvoke v.(v); virtualinvoke v.(1); v = interfaceinvoke v.("browser"); if v == null goto label; v = virtualinvoke v.("true"); if v == 0 goto label; v = v.; v = virtualinvoke v.("1.0"); if v == 0 goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("Queue Browser feature only valid for Stomp v.1+ clients!"); throw v; label: virtualinvoke v.(1); virtualinvoke v.(500); label: v = interfaceinvoke v.("selector"); if v == null goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("convert_string_expressions:\u0001"); virtualinvoke v.(v); label: staticinvoke (v, v, "activemq."); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = new org.apache.activemq.transport.stomp.ProtocolException; specialinvoke v.(java.lang.String)>("Invalid Subscription: cannot durably subscribe to a Queue destination!"); throw v; label: virtualinvoke v.(v); virtualinvoke v.(1); v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.activemq.transport.stomp.StompSubscription; v = interfaceinvoke v.("transformation"); v = v.; specialinvoke v.(org.apache.activemq.transport.stomp.ProtocolConverter,java.lang.String,org.apache.activemq.command.ConsumerInfo,java.lang.String,java.util.Map)>(v, v, v, v, v); v = v; goto label; label: v = new org.apache.activemq.transport.stomp.StompQueueBrowserSubscription; v = interfaceinvoke v.("transformation"); v = v.; specialinvoke v.(org.apache.activemq.transport.stomp.ProtocolConverter,java.lang.String,org.apache.activemq.command.ConsumerInfo,java.lang.String,java.util.Map)>(v, v, v, v, v); v = v; label: virtualinvoke v.(v); v = interfaceinvoke v.