class org.apache.activemq.broker.region.Topic$3 extends java.lang.Object implements java.lang.Runnable
{
final org.apache.activemq.command.Message val$message;
final org.apache.activemq.broker.ConnectionContext val$context;
final org.apache.activemq.broker.ProducerBrokerExchange val$producerExchange;
final boolean val$sendProducerAck;
final org.apache.activemq.command.ProducerInfo val$producerInfo;
final org.apache.activemq.broker.region.Topic this$0;
void <init>(org.apache.activemq.broker.region.Topic, org.apache.activemq.command.Message, org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.ProducerBrokerExchange, boolean, org.apache.activemq.command.ProducerInfo)
{
org.apache.activemq.broker.region.Topic$3 v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.broker.region.Topic v;
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.broker.ProducerBrokerExchange v;
boolean v;
v := @this: org.apache.activemq.broker.region.Topic$3;
v := @parameter: org.apache.activemq.broker.region.Topic;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange;
v := @parameter: boolean;
v := @parameter: org.apache.activemq.command.ProducerInfo;
v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.region.Topic this$0> = v;
v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.Message val$message> = v;
v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ConnectionContext val$context> = v;
v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ProducerBrokerExchange val$producerExchange> = v;
v.<org.apache.activemq.broker.region.Topic$3: boolean val$sendProducerAck> = v;
v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.ProducerInfo val$producerInfo> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void run()
{
org.apache.activemq.broker.region.Topic$3 v;
org.apache.activemq.broker.ConnectionContext v, v, v, v, v, v, v;
org.apache.activemq.command.Message v, v, v, v, v, v, v;
org.apache.activemq.management.CountStatisticImpl v;
byte v;
boolean v, v, v, v, v;
javax.jms.JMSException v;
java.lang.Exception v;
org.apache.activemq.command.ProducerAck v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.ProducerBrokerExchange v;
org.apache.activemq.command.Response v;
org.apache.activemq.broker.Broker v;
int v, v, v;
org.apache.activemq.broker.Connection v, v, v;
org.apache.activemq.broker.region.Topic v, v, v;
org.apache.activemq.command.ProducerId v;
org.apache.activemq.command.ExceptionResponse v;
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.transaction.Transaction v, v;
v := @this: org.apache.activemq.broker.region.Topic$3;
label:
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.Message val$message>;
v = virtualinvoke v.<org.apache.activemq.command.Message: boolean isInTransaction()>();
if v == 0 goto label;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ConnectionContext val$context>;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.transaction.Transaction getTransaction()>();
if v == null goto label;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ConnectionContext val$context>;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.transaction.Transaction getTransaction()>();
v = virtualinvoke v.<org.apache.activemq.transaction.Transaction: byte getState()>();
if v <= 1 goto label;
label:
v = new javax.jms.JMSException;
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>("Send transaction completed while waiting for space");
throw v;
label:
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.Message val$message>;
v = virtualinvoke v.<org.apache.activemq.command.Message: boolean isExpired()>();
if v == 0 goto label;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.region.Topic this$0>;
v = v.<org.apache.activemq.broker.region.Topic: org.apache.activemq.broker.Broker broker>;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ConnectionContext val$context>;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.Message val$message>;
interfaceinvoke v.<org.apache.activemq.broker.Broker: void messageExpired(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.broker.region.MessageReference,org.apache.activemq.broker.region.Subscription)>(v, v, null);
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.region.Topic this$0>;
v = virtualinvoke v.<org.apache.activemq.broker.region.Topic: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getExpired()>();
virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: void increment()>();
goto label;
label:
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.region.Topic this$0>;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ProducerBrokerExchange val$producerExchange>;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.Message val$message>;
virtualinvoke v.<org.apache.activemq.broker.region.Topic: void doMessageSend(org.apache.activemq.broker.ProducerBrokerExchange,org.apache.activemq.command.Message)>(v, v);
label:
v = v.<org.apache.activemq.broker.region.Topic$3: boolean val$sendProducerAck>;
if v == 0 goto label;
v = new org.apache.activemq.command.ProducerAck;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.ProducerInfo val$producerInfo>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ProducerId getProducerId()>();
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.Message val$message>;
v = virtualinvoke v.<org.apache.activemq.command.Message: int getSize()>();
specialinvoke v.<org.apache.activemq.command.ProducerAck: void <init>(org.apache.activemq.command.ProducerId,int)>(v, v);
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ConnectionContext val$context>;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.broker.Connection getConnection()>();
interfaceinvoke v.<org.apache.activemq.broker.Connection: void dispatchAsync(org.apache.activemq.command.Command)>(v);
goto label;
label:
v = new org.apache.activemq.command.Response;
specialinvoke v.<org.apache.activemq.command.Response: void <init>()>();
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.Message val$message>;
v = virtualinvoke v.<org.apache.activemq.command.Message: int getCommandId()>();
virtualinvoke v.<org.apache.activemq.command.Response: void setCorrelationId(int)>(v);
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ConnectionContext val$context>;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.broker.Connection getConnection()>();
interfaceinvoke v.<org.apache.activemq.broker.Connection: void dispatchAsync(org.apache.activemq.command.Command)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.broker.region.Topic$3: boolean val$sendProducerAck>;
if v != 0 goto label;
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ConnectionContext val$context>;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: boolean isInRecoveryMode()>();
if v != 0 goto label;
v = new org.apache.activemq.command.ExceptionResponse;
specialinvoke v.<org.apache.activemq.command.ExceptionResponse: void <init>(java.lang.Throwable)>(v);
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.command.Message val$message>;
v = virtualinvoke v.<org.apache.activemq.command.Message: int getCommandId()>();
virtualinvoke v.<org.apache.activemq.command.ExceptionResponse: void setCorrelationId(int)>(v);
v = v.<org.apache.activemq.broker.region.Topic$3: org.apache.activemq.broker.ConnectionContext val$context>;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.broker.Connection getConnection()>();
interfaceinvoke v.<org.apache.activemq.broker.Connection: void dispatchAsync(org.apache.activemq.command.Command)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
}
}