public class org.apache.activemq.ActiveMQConnectionConsumer extends java.lang.Object implements javax.jms.ConnectionConsumer, org.apache.activemq.ActiveMQDispatcher
{
private org.apache.activemq.ActiveMQConnection connection;
private javax.jms.ServerSessionPool sessionPool;
private org.apache.activemq.command.ConsumerInfo consumerInfo;
private boolean closed;
protected void <init>(org.apache.activemq.ActiveMQConnection, javax.jms.ServerSessionPool, org.apache.activemq.command.ConsumerInfo) throws javax.jms.JMSException
{
org.apache.activemq.ActiveMQConnectionConsumer v;
org.apache.activemq.ActiveMQConnection v, v, v, v;
org.apache.activemq.command.ConsumerId v;
javax.jms.ServerSessionPool v;
org.apache.activemq.command.ConsumerInfo v, v, v;
v := @this: org.apache.activemq.ActiveMQConnectionConsumer;
v := @parameter: org.apache.activemq.ActiveMQConnection;
v := @parameter: javax.jms.ServerSessionPool;
v := @parameter: org.apache.activemq.command.ConsumerInfo;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection> = v;
v.<org.apache.activemq.ActiveMQConnectionConsumer: javax.jms.ServerSessionPool sessionPool> = v;
v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.command.ConsumerInfo consumerInfo> = v;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection>;
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: void addConnectionConsumer(org.apache.activemq.ActiveMQConnectionConsumer)>(v);
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection>;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.command.ConsumerInfo consumerInfo>;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ConsumerId getConsumerId()>();
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: void addDispatcher(org.apache.activemq.command.ConsumerId,org.apache.activemq.ActiveMQDispatcher)>(v, v);
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection>;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.command.ConsumerInfo consumerInfo>;
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: org.apache.activemq.command.Response syncSendPacket(org.apache.activemq.command.Command)>(v);
return;
}
public javax.jms.ServerSessionPool getServerSessionPool() throws javax.jms.JMSException
{
org.apache.activemq.ActiveMQConnectionConsumer v;
javax.jms.IllegalStateException v;
javax.jms.ServerSessionPool v;
boolean v;
v := @this: org.apache.activemq.ActiveMQConnectionConsumer;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: boolean closed>;
if v == 0 goto label;
v = new javax.jms.IllegalStateException;
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>("The Connection Consumer is closed");
throw v;
label:
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: javax.jms.ServerSessionPool sessionPool>;
return v;
}
public void close() throws javax.jms.JMSException
{
org.apache.activemq.ActiveMQConnectionConsumer v;
org.apache.activemq.ActiveMQConnection v;
org.apache.activemq.command.ConsumerInfo v;
org.apache.activemq.command.RemoveInfo v;
boolean v;
v := @this: org.apache.activemq.ActiveMQConnectionConsumer;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: boolean closed>;
if v != 0 goto label;
virtualinvoke v.<org.apache.activemq.ActiveMQConnectionConsumer: void dispose()>();
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection>;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.command.ConsumerInfo consumerInfo>;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.RemoveInfo createRemoveCommand()>();
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: void asyncSendPacket(org.apache.activemq.command.Command)>(v);
label:
return;
}
public void dispose()
{
org.apache.activemq.ActiveMQConnectionConsumer v;
org.apache.activemq.ActiveMQConnection v, v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.command.ConsumerInfo v;
boolean v;
v := @this: org.apache.activemq.ActiveMQConnectionConsumer;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: boolean closed>;
if v != 0 goto label;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection>;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.command.ConsumerInfo consumerInfo>;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ConsumerId getConsumerId()>();
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: void removeDispatcher(org.apache.activemq.command.ConsumerId)>(v);
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection>;
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: void removeConnectionConsumer(org.apache.activemq.ActiveMQConnectionConsumer)>(v);
v.<org.apache.activemq.ActiveMQConnectionConsumer: boolean closed> = 1;
label:
return;
}
public void dispatch(org.apache.activemq.command.MessageDispatch)
{
org.apache.activemq.ActiveMQConnectionConsumer v;
org.apache.activemq.ActiveMQConnection v, v;
javax.jms.JMSException v, v;
javax.jms.ServerSessionPool v;
javax.jms.Session v;
org.apache.activemq.command.MessageDispatch v;
javax.jms.ServerSession v;
java.lang.Class v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.activemq.ActiveMQConnectionConsumer;
v := @parameter: org.apache.activemq.command.MessageDispatch;
label:
virtualinvoke v.<org.apache.activemq.command.MessageDispatch: void setConsumer(java.lang.Object)>(v);
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: javax.jms.ServerSessionPool sessionPool>;
v = interfaceinvoke v.<javax.jms.ServerSessionPool: javax.jms.ServerSession getServerSession()>();
v = interfaceinvoke v.<javax.jms.ServerSession: javax.jms.Session getSession()>();
v = v instanceof org.apache.activemq.ActiveMQSession;
if v != 0 goto label;
v = v instanceof org.apache.activemq.ActiveMQTopicSession;
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession getNext()>();
goto label;
label:
v = v instanceof org.apache.activemq.ActiveMQQueueSession;
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.ActiveMQQueueSession: javax.jms.QueueSession getNext()>();
goto label;
label:
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection>;
v = new javax.jms.JMSException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class)>(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[])>("Session pool provided an invalid session type: \u0001");
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: void onClientInternalException(java.lang.Throwable)>(v);
label:
return;
label:
virtualinvoke v.<org.apache.activemq.ActiveMQSession: void dispatch(org.apache.activemq.command.MessageDispatch)>(v);
interfaceinvoke v.<javax.jms.ServerSession: void start()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.ActiveMQConnection connection>;
virtualinvoke v.<org.apache.activemq.ActiveMQConnection: void onAsyncException(java.lang.Throwable)>(v);
label:
return;
catch javax.jms.JMSException from label to label with label;
catch javax.jms.JMSException from label to label with label;
}
public java.lang.String toString()
{
org.apache.activemq.ActiveMQConnectionConsumer v;
java.lang.String v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.command.ConsumerInfo v;
v := @this: org.apache.activemq.ActiveMQConnectionConsumer;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.command.ConsumerInfo consumerInfo>;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ConsumerId getConsumerId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ConsumerId)>(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[])>("ActiveMQConnectionConsumer { value=\u }");
return v;
}
public void clearMessagesInProgress(java.util.concurrent.atomic.AtomicInteger)
{
org.apache.activemq.ActiveMQConnectionConsumer v;
java.util.concurrent.atomic.AtomicInteger v;
v := @this: org.apache.activemq.ActiveMQConnectionConsumer;
v := @parameter: java.util.concurrent.atomic.AtomicInteger;
return;
}
public org.apache.activemq.command.ConsumerInfo getConsumerInfo()
{
org.apache.activemq.ActiveMQConnectionConsumer v;
org.apache.activemq.command.ConsumerInfo v;
v := @this: org.apache.activemq.ActiveMQConnectionConsumer;
v = v.<org.apache.activemq.ActiveMQConnectionConsumer: org.apache.activemq.command.ConsumerInfo consumerInfo>;
return v;
}
}