class org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction extends java.lang.Object implements org.apache.activemq.state.ResponseHandler
{
private final org.apache.activemq.command.TransactionInfo info;
final org.apache.activemq.state.ConnectionStateTracker this$0;
public void <init>(org.apache.activemq.state.ConnectionStateTracker, org.apache.activemq.command.TransactionInfo)
{
org.apache.activemq.command.TransactionInfo v;
org.apache.activemq.state.ConnectionStateTracker v;
org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction v;
v := @this: org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction;
v := @parameter: org.apache.activemq.state.ConnectionStateTracker;
v := @parameter: org.apache.activemq.command.TransactionInfo;
v.<org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction: org.apache.activemq.state.ConnectionStateTracker this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction: org.apache.activemq.command.TransactionInfo info> = v;
return;
}
public void onResponse(org.apache.activemq.command.Command)
{
org.apache.activemq.command.Command v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.state.ConnectionStateTracker v;
org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction v;
java.util.concurrent.ConcurrentMap v;
org.apache.activemq.command.TransactionInfo v, v;
java.lang.Object v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction;
v := @parameter: org.apache.activemq.command.Command;
v = v.<org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction: org.apache.activemq.command.TransactionInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.TransactionInfo: org.apache.activemq.command.ConnectionId getConnectionId()>();
v = v.<org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction: org.apache.activemq.state.ConnectionStateTracker this$0>;
v = v.<org.apache.activemq.state.ConnectionStateTracker: java.util.concurrent.ConcurrentMap connectionStates>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = v.<org.apache.activemq.state.ConnectionStateTracker$RemoveTransactionAction: org.apache.activemq.command.TransactionInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.TransactionInfo: org.apache.activemq.command.TransactionId getTransactionId()>();
virtualinvoke v.<org.apache.activemq.state.ConnectionState: org.apache.activemq.state.TransactionState removeTransactionState(org.apache.activemq.command.TransactionId)>(v);
label:
return;
}
}