public class org.apache.activemq.transport.amqp.protocol.AmqpSession extends java.lang.Object implements org.apache.activemq.transport.amqp.protocol.AmqpResource
{
private static final org.slf4j.Logger LOG;
private final java.util.Map consumers;
private final org.apache.activemq.transport.amqp.protocol.AmqpConnection connection;
private final org.apache.qpid.proton.engine.Session protonSession;
private final org.apache.activemq.command.SessionId sessionId;
private boolean enlisted;
private long nextProducerId;
private long nextConsumerId;
public void <init>(org.apache.activemq.transport.amqp.protocol.AmqpConnection, org.apache.activemq.command.SessionId, org.apache.qpid.proton.engine.Session)
{
org.apache.activemq.command.SessionId v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
org.apache.qpid.proton.engine.Session v;
java.util.HashMap v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.activemq.transport.amqp.protocol.AmqpConnection;
v := @parameter: org.apache.activemq.command.SessionId;
v := @parameter: org.apache.qpid.proton.engine.Session;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: java.util.Map consumers> = v;
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: long nextProducerId> = 0L;
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: long nextConsumerId> = 0L;
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection> = v;
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.SessionId sessionId> = v;
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.qpid.proton.engine.Session protonSession> = v;
return;
}
public void open()
{
org.slf4j.Logger v;
org.apache.activemq.command.SessionId v, v;
org.apache.qpid.proton.engine.Session v, v, v;
org.apache.activemq.command.SessionInfo v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = <org.apache.activemq.transport.amqp.protocol.AmqpSession: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.SessionId getSessionId()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Session {} opened", v);
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.qpid.proton.engine.Session getEndpoint()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Session: void setContext(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.qpid.proton.engine.Session getEndpoint()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Session: void setIncomingCapacity(int)>(2147483647);
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.qpid.proton.engine.Session getEndpoint()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Session: void open()>();
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = new org.apache.activemq.command.SessionInfo;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.SessionId getSessionId()>();
specialinvoke v.<org.apache.activemq.command.SessionInfo: void <init>(org.apache.activemq.command.SessionId)>(v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: void sendToActiveMQ(org.apache.activemq.command.Command)>(v);
return;
}
public void close()
{
org.slf4j.Logger v;
org.apache.activemq.command.SessionId v, v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
org.apache.activemq.transport.amqp.protocol.AmqpSession$1 v;
org.apache.activemq.command.RemoveInfo v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = <org.apache.activemq.transport.amqp.protocol.AmqpSession: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.SessionId getSessionId()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Session {} closed", v);
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = new org.apache.activemq.command.RemoveInfo;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.SessionId getSessionId()>();
specialinvoke v.<org.apache.activemq.command.RemoveInfo: void <init>(org.apache.activemq.command.DataStructure)>(v);
v = new org.apache.activemq.transport.amqp.protocol.AmqpSession$1;
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession$1: void <init>(org.apache.activemq.transport.amqp.protocol.AmqpSession)>(v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: void sendToActiveMQ(org.apache.activemq.command.Command,org.apache.activemq.transport.amqp.ResponseHandler)>(v, v);
return;
}
public void commit(org.apache.activemq.command.LocalTransactionId) throws java.lang.Exception
{
java.util.Iterator v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
java.util.Collection v;
java.util.Map v;
org.apache.activemq.command.LocalTransactionId v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.activemq.command.LocalTransactionId;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: java.util.Map consumers>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSender: void commit(org.apache.activemq.command.LocalTransactionId)>(v);
goto label;
label:
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: boolean enlisted> = 0;
return;
}
public void rollback(org.apache.activemq.command.LocalTransactionId) throws java.lang.Exception
{
java.util.Iterator v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
java.util.Collection v;
java.util.Map v;
org.apache.activemq.command.LocalTransactionId v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.activemq.command.LocalTransactionId;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: java.util.Map consumers>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSender: void rollback(org.apache.activemq.command.LocalTransactionId)>(v);
goto label;
label:
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: boolean enlisted> = 0;
return;
}
public void flushPendingMessages() throws java.lang.Exception
{
java.util.Iterator v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
java.util.Collection v;
java.util.Map v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: java.util.Map consumers>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSender: void pumpOutbound()>();
goto label;
label:
return;
}
public void createCoordinator(org.apache.qpid.proton.engine.Receiver) throws java.lang.Exception
{
org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
int v;
org.apache.qpid.proton.engine.Receiver v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.qpid.proton.engine.Receiver;
v = new org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator;
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator: void <init>(org.apache.activemq.transport.amqp.protocol.AmqpSession,org.apache.qpid.proton.engine.Receiver)>(v, v);
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: int getConfiguredReceiverCredit()>();
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator: void flow(int)>(v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator: void open()>();
return;
}
public void createReceiver(org.apache.qpid.proton.engine.Receiver) throws java.lang.Exception
{
org.apache.activemq.transport.amqp.protocol.AmqpReceiver v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
org.apache.activemq.transport.amqp.protocol.AmqpSession$2 v;
boolean v, v, v, v;
org.apache.activemq.transport.amqp.protocol.AmqpSession$3 v;
org.apache.qpid.proton.amqp.messaging.DeleteOnClose v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.qpid.proton.amqp.transport.ErrorCondition v;
java.util.List v;
org.apache.qpid.proton.amqp.messaging.Target v;
java.util.HashMap v;
org.apache.qpid.proton.amqp.Symbol v, v, v, v, v, v;
org.apache.qpid.proton.amqp.transport.Target v;
org.apache.qpid.proton.engine.Receiver v;
java.lang.String v, v, v, v, v, v, v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v, v;
org.apache.qpid.proton.amqp.Symbol[] v, v, v, v;
org.slf4j.Logger v;
org.apache.activemq.command.ProducerId v, v;
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.transport.amqp.AmqpProtocolException v, v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.qpid.proton.engine.Receiver;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Receiver: org.apache.qpid.proton.amqp.transport.Target getRemoteTarget()>();
v = new org.apache.activemq.command.ProducerInfo;
v = specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.ProducerId getNextProducerId()>();
specialinvoke v.<org.apache.activemq.command.ProducerInfo: void <init>(org.apache.activemq.command.ProducerId)>(v);
v = new org.apache.activemq.transport.amqp.protocol.AmqpReceiver;
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpReceiver: void <init>(org.apache.activemq.transport.amqp.protocol.AmqpSession,org.apache.qpid.proton.engine.Receiver,org.apache.activemq.command.ProducerInfo)>(v, v, v);
v = <org.apache.activemq.transport.amqp.protocol.AmqpSession: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ProducerId getProducerId()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Receiver: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("opening new receiver {} on link: {}", v, v);
label:
v = null;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Target: java.lang.String getAddress()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Target: boolean getDynamic()>();
if v == 0 goto label;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Target: org.apache.qpid.proton.amqp.Symbol[] getCapabilities()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: org.apache.activemq.command.ActiveMQDestination createTemporaryDestination(org.apache.qpid.proton.engine.Link,org.apache.qpid.proton.amqp.Symbol[])>(v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol LIFETIME_POLICY>;
v = staticinvoke <org.apache.qpid.proton.amqp.messaging.DeleteOnClose: org.apache.qpid.proton.amqp.messaging.DeleteOnClose getInstance()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.qpid.proton.amqp.messaging.Target;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Target: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getQualifiedName()>();
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Target: void setAddress(java.lang.String)>(v);
v = newarray (org.apache.qpid.proton.amqp.Symbol)[1];
v = staticinvoke <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol getDestinationTypeSymbol(org.apache.activemq.command.ActiveMQDestination)>(v);
v[0] = v;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Target: void setCapabilities(org.apache.qpid.proton.amqp.Symbol[])>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Target: void setDynamic(boolean)>(1);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Target: void setDynamicNodeProperties(java.util.Map)>(v);
interfaceinvoke v.<org.apache.qpid.proton.engine.Receiver: void setTarget(org.apache.qpid.proton.amqp.transport.Target)>(v);
v = new org.apache.activemq.transport.amqp.protocol.AmqpSession$2;
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession$2: void <init>(org.apache.activemq.transport.amqp.protocol.AmqpSession,org.apache.activemq.transport.amqp.protocol.AmqpReceiver)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpReceiver: void addCloseAction(java.lang.Runnable)>(v);
goto label;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = staticinvoke <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.activemq.command.ActiveMQDestination createDestination(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTemporary()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTempDestination: java.lang.String getConnectionId()>();
if v != null goto label;
v = new org.apache.activemq.transport.amqp.AmqpProtocolException;
v = <org.apache.qpid.proton.amqp.transport.AmqpError: org.apache.qpid.proton.amqp.Symbol PRECONDITION_FAILED>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Symbol: java.lang.String toString()>();
specialinvoke v.<org.apache.activemq.transport.amqp.AmqpProtocolException: void <init>(java.lang.String,java.lang.String)>(v, "Not a broker created temp destination");
throw v;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Receiver: org.apache.qpid.proton.amqp.Symbol[] getRemoteDesiredCapabilities()>();
if v == null goto label;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol DELAYED_DELIVERY>;
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = newarray (org.apache.qpid.proton.amqp.Symbol)[1];
v = <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol DELAYED_DELIVERY>;
v[0] = v;
interfaceinvoke v.<org.apache.qpid.proton.engine.Receiver: void setOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[])>(v);
label:
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpReceiver: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = new org.apache.activemq.transport.amqp.protocol.AmqpSession$3;
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession$3: void <init>(org.apache.activemq.transport.amqp.protocol.AmqpSession,org.apache.activemq.transport.amqp.protocol.AmqpReceiver)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: void sendToActiveMQ(org.apache.activemq.command.Command,org.apache.activemq.transport.amqp.ResponseHandler)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.qpid.proton.amqp.transport.ErrorCondition;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.AmqpProtocolException: java.lang.String getSymbolicName()>();
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol getSymbol(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.amqp.AmqpProtocolException: java.lang.String getMessage()>();
specialinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void <init>(org.apache.qpid.proton.amqp.Symbol,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpReceiver: void close(org.apache.qpid.proton.amqp.transport.ErrorCondition)>(v);
label:
return;
catch org.apache.activemq.transport.amqp.AmqpProtocolException from label to label with label;
}
public void createSender(org.apache.qpid.proton.engine.Sender) throws java.lang.Exception
{
org.apache.activemq.command.ConsumerId v, v;
org.apache.activemq.transport.amqp.protocol.AmqpSender v;
java.util.Map v, v, v, v, v;
org.apache.activemq.transport.amqp.protocol.AmqpSession$5 v;
org.apache.activemq.transport.amqp.protocol.AmqpSession$4 v;
java.lang.Object[] v, v;
org.apache.qpid.proton.engine.Sender v;
org.apache.activemq.transport.amqp.protocol.AmqpNoLocalFilter v;
org.apache.qpid.proton.amqp.Symbol v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.command.ConsumerInfo v, v;
java.util.Map$Entry v, v;
org.apache.qpid.proton.amqp.messaging.TerminusDurability v, v, v, v, v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
org.apache.activemq.transport.amqp.protocol.AmqpJmsSelectorFilter v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.amqp.messaging.DeleteOnClose v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.qpid.proton.amqp.transport.ErrorCondition v, v, v;
java.util.HashMap v, v, v, v;
int v, v, v, v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v, v, v;
org.apache.qpid.proton.amqp.Symbol[] v, v;
org.slf4j.Logger v, v;
org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy v;
org.apache.qpid.proton.amqp.messaging.Source v, v, v, v;
org.apache.qpid.proton.amqp.transport.Source v;
javax.jms.InvalidSelectorException v;
java.lang.Object v, v, v, v, v, v;
org.apache.activemq.transport.amqp.AmqpProtocolException v, v, v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.qpid.proton.engine.Sender;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Sender: org.apache.qpid.proton.amqp.transport.Source getRemoteSource()>();
v = new org.apache.activemq.command.ConsumerInfo;
v = specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.ConsumerId getNextConsumerId()>();
specialinvoke v.<org.apache.activemq.command.ConsumerInfo: void <init>(org.apache.activemq.command.ConsumerId)>(v);
v = new org.apache.activemq.transport.amqp.protocol.AmqpSender;
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSender: void <init>(org.apache.activemq.transport.amqp.protocol.AmqpSession,org.apache.qpid.proton.engine.Sender,org.apache.activemq.command.ConsumerInfo)>(v, v, v);
v = <org.apache.activemq.transport.amqp.protocol.AmqpSession: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ConsumerId getConsumerId()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Sender: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("opening new sender {} on link: {}", v, v);
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Sender: void setContext(java.lang.Object)>(v);
v = 0;
v = null;
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: java.util.Map getFilter()>();
v = <org.apache.activemq.transport.amqp.AmqpSupport: java.lang.Object[] JMS_SELECTOR_FILTER_IDS>;
v = staticinvoke <org.apache.activemq.transport.amqp.AmqpSupport: java.util.Map$Entry findFilter(java.util.Map,java.lang.Object[])>(v, v);
if v == null goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<org.apache.qpid.proton.amqp.DescribedType: java.lang.Object getDescribed()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
staticinvoke <org.apache.activemq.selector.SelectorParser: org.apache.activemq.filter.BooleanExpression parse(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.qpid.proton.amqp.transport.ErrorCondition;
v = <org.apache.qpid.proton.amqp.transport.AmqpError: org.apache.qpid.proton.amqp.Symbol INVALID_FIELD>;
v = virtualinvoke v.<javax.jms.InvalidSelectorException: java.lang.String getMessage()>();
specialinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void <init>(org.apache.qpid.proton.amqp.Symbol,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSender: void close(org.apache.qpid.proton.amqp.transport.ErrorCondition)>(v);
label:
return;
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: java.util.Map getFilter()>();
v = <org.apache.activemq.transport.amqp.AmqpSupport: java.lang.Object[] NO_LOCAL_FILTER_IDS>;
v = staticinvoke <org.apache.activemq.transport.amqp.AmqpSupport: java.util.Map$Entry findFilter(java.util.Map,java.lang.Object[])>(v, v);
if v == null goto label;
v = 1;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
if v != null goto label;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Sender: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: org.apache.activemq.command.ConsumerInfo lookupSubscription(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = new org.apache.qpid.proton.amqp.messaging.Source;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void <init>()>();
v = v;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getQualifiedName()>();
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setAddress(java.lang.String)>(v);
v = <org.apache.qpid.proton.amqp.messaging.TerminusDurability: org.apache.qpid.proton.amqp.messaging.TerminusDurability UNSETTLED_STATE>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setDurable(org.apache.qpid.proton.amqp.messaging.TerminusDurability)>(v);
v = <org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy: org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy NEVER>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setExpiryPolicy(org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy)>(v);
v = <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol COPY>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setDistributionMode(org.apache.qpid.proton.amqp.Symbol)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: boolean isNoLocal()>();
if v == 0 goto label;
v = <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol NO_LOCAL_NAME>;
v = <org.apache.activemq.transport.amqp.protocol.AmqpNoLocalFilter: org.apache.activemq.transport.amqp.protocol.AmqpNoLocalFilter NO_LOCAL>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: java.lang.String getSelector()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: java.lang.String getSelector()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("");
if v != 0 goto label;
v = <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol JMS_SELECTOR_NAME>;
v = new org.apache.activemq.transport.amqp.protocol.AmqpJmsSelectorFilter;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: java.lang.String getSelector()>();
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpJmsSelectorFilter: void <init>(java.lang.String)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new org.apache.qpid.proton.amqp.transport.ErrorCondition;
v = <org.apache.qpid.proton.amqp.transport.AmqpError: org.apache.qpid.proton.amqp.Symbol NOT_FOUND>;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Sender: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unknown subscription link: \u0001");
specialinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void <init>(org.apache.qpid.proton.amqp.Symbol,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSender: void close(org.apache.qpid.proton.amqp.transport.ErrorCondition)>(v);
label:
return;
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: boolean getDynamic()>();
if v == 0 goto label;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: org.apache.qpid.proton.amqp.Symbol[] getCapabilities()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: org.apache.activemq.command.ActiveMQDestination createTemporaryDestination(org.apache.qpid.proton.engine.Link,org.apache.qpid.proton.amqp.Symbol[])>(v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol LIFETIME_POLICY>;
v = staticinvoke <org.apache.qpid.proton.amqp.messaging.DeleteOnClose: org.apache.qpid.proton.amqp.messaging.DeleteOnClose getInstance()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.qpid.proton.amqp.messaging.Source;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void <init>()>();
v = v;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getQualifiedName()>();
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setAddress(java.lang.String)>(v);
v = newarray (org.apache.qpid.proton.amqp.Symbol)[1];
v = staticinvoke <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol getDestinationTypeSymbol(org.apache.activemq.command.ActiveMQDestination)>(v);
v[0] = v;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setCapabilities(org.apache.qpid.proton.amqp.Symbol[])>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setDynamic(boolean)>(1);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setDynamicNodeProperties(java.util.Map)>(v);
v = new org.apache.activemq.transport.amqp.protocol.AmqpSession$4;
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession$4: void <init>(org.apache.activemq.transport.amqp.protocol.AmqpSession,org.apache.activemq.transport.amqp.protocol.AmqpSender)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSender: void addCloseAction(java.lang.Runnable)>(v);
goto label;
label:
v = staticinvoke <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.activemq.command.ActiveMQDestination createDestination(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTemporary()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTempDestination: java.lang.String getConnectionId()>();
if v != null goto label;
v = new org.apache.activemq.transport.amqp.AmqpProtocolException;
v = <org.apache.qpid.proton.amqp.transport.AmqpError: org.apache.qpid.proton.amqp.Symbol INVALID_FIELD>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Symbol: java.lang.String toString()>();
specialinvoke v.<org.apache.activemq.transport.amqp.AmqpProtocolException: void <init>(java.lang.String,java.lang.String)>(v, "Not a broker created temp destination");
throw v;
label:
v = v;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v == 0 goto label;
v = null;
goto label;
label:
v = v;
label:
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: void setFilter(java.util.Map)>(v);
interfaceinvoke v.<org.apache.qpid.proton.engine.Sender: void setSource(org.apache.qpid.proton.amqp.transport.Source)>(v);
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Sender: int getRemoteCredit()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.util.Map getOptions()>();
if v == null goto label;
v = new java.util.HashMap;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.util.Map getOptions()>();
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = staticinvoke <org.apache.activemq.util.IntrospectionSupport: java.util.Map extractProperties(java.util.Map,java.lang.String)>(v, "consumer.");
staticinvoke <org.apache.activemq.util.IntrospectionSupport: boolean setProperties(java.lang.Object,java.util.Map)>(v, v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v <= 0 goto label;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,java.util.Map)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("There are \u consumer options that couldn\'t be set on the consumer. Check the options are spelled correctly. Unknown parameters=[\u]. This consumer cannot be started.");
v = <org.apache.activemq.transport.amqp.protocol.AmqpSession: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = new org.apache.activemq.transport.amqp.AmqpProtocolException;
v = <org.apache.qpid.proton.amqp.transport.AmqpError: org.apache.qpid.proton.amqp.Symbol INVALID_FIELD>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Symbol: java.lang.String toString()>();
specialinvoke v.<org.apache.activemq.transport.amqp.AmqpProtocolException: void <init>(java.lang.String,java.lang.String)>(v, v);
throw v;
label:
virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: void setSelector(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: void setNoRangeAcks(boolean)>(1);
virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
if v < 0 goto label;
v = v;
goto label;
label:
v = 0;
label:
virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: void setPrefetchSize(int)>(v);
virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: void setDispatchAsync(boolean)>(1);
virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: void setNoLocal(boolean)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: org.apache.qpid.proton.amqp.Symbol getDistributionMode()>();
v = <org.apache.activemq.transport.amqp.AmqpSupport: org.apache.qpid.proton.amqp.Symbol COPY>;
if v != v goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: void setBrowser(boolean)>(1);
label:
v = <org.apache.qpid.proton.amqp.messaging.TerminusDurability: org.apache.qpid.proton.amqp.messaging.TerminusDurability UNSETTLED_STATE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: org.apache.qpid.proton.amqp.messaging.TerminusDurability getDurable()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.TerminusDurability: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.qpid.proton.amqp.messaging.TerminusDurability: org.apache.qpid.proton.amqp.messaging.TerminusDurability CONFIGURATION>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Source: org.apache.qpid.proton.amqp.messaging.TerminusDurability getDurable()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.TerminusDurability: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Sender: java.lang.String getName()>();
virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: void setSubscriptionName(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = new org.apache.activemq.transport.amqp.protocol.AmqpSession$5;
specialinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSession$5: void <init>(org.apache.activemq.transport.amqp.protocol.AmqpSession,org.apache.activemq.transport.amqp.protocol.AmqpSender)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: void sendToActiveMQ(org.apache.activemq.command.Command,org.apache.activemq.transport.amqp.ResponseHandler)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.qpid.proton.amqp.transport.ErrorCondition;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.AmqpProtocolException: java.lang.String getSymbolicName()>();
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol getSymbol(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.amqp.AmqpProtocolException: java.lang.String getMessage()>();
specialinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void <init>(org.apache.qpid.proton.amqp.Symbol,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpSender: void close(org.apache.qpid.proton.amqp.transport.ErrorCondition)>(v);
label:
return;
catch javax.jms.InvalidSelectorException from label to label with label;
catch org.apache.activemq.transport.amqp.AmqpProtocolException from label to label with label;
catch org.apache.activemq.transport.amqp.AmqpProtocolException from label to label with label;
catch org.apache.activemq.transport.amqp.AmqpProtocolException from label to label with label;
}
public void pumpProtonToSocket()
{
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: void pumpProtonToSocket()>();
return;
}
public void registerSender(org.apache.activemq.command.ConsumerId, org.apache.activemq.transport.amqp.protocol.AmqpSender)
{
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
java.util.Map v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
org.apache.activemq.transport.amqp.protocol.AmqpSender v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.activemq.command.ConsumerId;
v := @parameter: org.apache.activemq.transport.amqp.protocol.AmqpSender;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: java.util.Map consumers>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: void registerSender(org.apache.activemq.command.ConsumerId,org.apache.activemq.transport.amqp.protocol.AmqpSender)>(v, v);
return;
}
public void unregisterSender(org.apache.activemq.command.ConsumerId)
{
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
java.util.Map v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.activemq.command.ConsumerId;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: java.util.Map consumers>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: void unregisterSender(org.apache.activemq.command.ConsumerId)>(v);
return;
}
public void enlist(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
org.apache.activemq.command.TransactionId v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
boolean v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v := @parameter: org.apache.activemq.command.TransactionId;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: boolean enlisted>;
if v != 0 goto label;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator getTxCoordinator(org.apache.activemq.command.TransactionId)>(v);
virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator: void enlist(org.apache.activemq.transport.amqp.protocol.AmqpSession)>(v);
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: boolean enlisted> = 1;
label:
return;
}
public org.apache.activemq.transport.amqp.protocol.AmqpConnection getConnection()
{
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
return v;
}
public org.apache.activemq.command.SessionId getSessionId()
{
org.apache.activemq.command.SessionId v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.SessionId sessionId>;
return v;
}
public org.apache.qpid.proton.engine.Session getEndpoint()
{
org.apache.qpid.proton.engine.Session v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.qpid.proton.engine.Session protonSession>;
return v;
}
public long getMaxFrameSize()
{
long v;
org.apache.activemq.transport.amqp.protocol.AmqpConnection v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.transport.amqp.protocol.AmqpConnection connection>;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.protocol.AmqpConnection: long getMaxFrameSize()>();
return v;
}
private org.apache.activemq.command.ConsumerId getNextConsumerId()
{
org.apache.activemq.command.SessionId v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
long v, v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = new org.apache.activemq.command.ConsumerId;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.SessionId sessionId>;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: long nextConsumerId>;
v = v + 1L;
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: long nextConsumerId> = v;
specialinvoke v.<org.apache.activemq.command.ConsumerId: void <init>(org.apache.activemq.command.SessionId,long)>(v, v);
return v;
}
private org.apache.activemq.command.ProducerId getNextProducerId()
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.command.SessionId v;
org.apache.activemq.transport.amqp.protocol.AmqpSession v;
long v, v;
v := @this: org.apache.activemq.transport.amqp.protocol.AmqpSession;
v = new org.apache.activemq.command.ProducerId;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.apache.activemq.command.SessionId sessionId>;
v = v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: long nextProducerId>;
v = v + 1L;
v.<org.apache.activemq.transport.amqp.protocol.AmqpSession: long nextProducerId> = v;
specialinvoke v.<org.apache.activemq.command.ProducerId: void <init>(org.apache.activemq.command.SessionId,long)>(v, v);
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/transport/amqp/protocol/AmqpSession;");
<org.apache.activemq.transport.amqp.protocol.AmqpSession: org.slf4j.Logger LOG> = v;
return;
}
}