class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 extends java.lang.Object implements org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$LastAckCommand
{
final org.apache.activemq.command.MessageAck val$ack;
final org.apache.activemq.store.TopicMessageStore val$topicMessageStore;
final java.lang.String val$clientId;
final java.lang.String val$subscriptionName;
final org.apache.activemq.command.MessageId val$messageId;
final org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore this$0;
void <init>(org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore, org.apache.activemq.command.MessageAck, org.apache.activemq.store.TopicMessageStore, java.lang.String, java.lang.String, org.apache.activemq.command.MessageId)
{
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore v;
java.lang.String v, v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v := @parameter: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore;
v := @parameter: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.store.TopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.activemq.command.MessageId;
v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore this$0> = v;
v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.command.MessageAck val$ack> = v;
v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.store.TopicMessageStore val$topicMessageStore> = v;
v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$clientId> = v;
v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$subscriptionName> = v;
v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.command.MessageId val$messageId> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.apache.activemq.command.MessageAck getMessageAck()
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.command.MessageAck val$ack>;
return v;
}
public void run(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
org.apache.activemq.command.MessageId v;
java.lang.String v, v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.store.TopicMessageStore val$topicMessageStore>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$clientId>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$subscriptionName>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.command.MessageId val$messageId>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.command.MessageAck val$ack>;
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void acknowledge(org.apache.activemq.broker.ConnectionContext,java.lang.String,java.lang.String,org.apache.activemq.command.MessageId,org.apache.activemq.command.MessageAck)>(v, v, v, v, v);
return;
}
public org.apache.activemq.store.MessageStore getMessageStore()
{
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.store.TopicMessageStore val$topicMessageStore>;
return v;
}
public void rollback(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.TopicMessageStore v;
java.lang.String v, v, v, v;
org.apache.activemq.store.PersistenceAdapter v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.store.TopicMessageStore val$topicMessageStore>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore this$0>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: org.apache.activemq.command.MessageAck val$ack>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$subscriptionName>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$clientId>;
virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: void rollbackLastAck(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.store.jdbc.JDBCTopicMessageStore,org.apache.activemq.command.MessageAck,java.lang.String,java.lang.String)>(v, v, v, v, v);
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$clientId>;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$subscriptionName>;
virtualinvoke v.<org.apache.activemq.store.jdbc.JDBCTopicMessageStore: void complete(java.lang.String,java.lang.String)>(v, v);
return;
}
public java.lang.String getClientId()
{
java.lang.String v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$clientId>;
return v;
}
public java.lang.String getSubName()
{
java.lang.String v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v = v.<org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3: java.lang.String val$subscriptionName>;
return v;
}
public long getSequence()
{
java.lang.IllegalStateException v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Sequence id must be inferred from ack");
throw v;
}
public byte getPriority()
{
java.lang.IllegalStateException v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Priority must be inferred from ack or row");
throw v;
}
public void setMessageStore(org.apache.activemq.store.jdbc.JDBCTopicMessageStore)
{
java.lang.IllegalStateException v;
org.apache.activemq.store.jdbc.JDBCTopicMessageStore v;
org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3 v;
v := @this: org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore$3;
v := @parameter: org.apache.activemq.store.jdbc.JDBCTopicMessageStore;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("message store already known!");
throw v;
}
}