class org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation extends org.apache.activemq.store.kahadb.TempMessageDatabase$Operation
{
final org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command;
private final org.apache.activemq.util.ByteSequence data;
final org.apache.activemq.store.kahadb.TempMessageDatabase this$0;
public void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase, org.apache.activemq.store.kahadb.data.KahaAddMessageCommand, org.apache.activemq.util.ByteSequence)
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation v;
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation;
v := @parameter: org.apache.activemq.store.kahadb.TempMessageDatabase;
v := @parameter: org.apache.activemq.store.kahadb.data.KahaAddMessageCommand;
v := @parameter: org.apache.activemq.util.ByteSequence;
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation: org.apache.activemq.store.kahadb.TempMessageDatabase this$0> = v;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase$Operation: void <init>(org.apache.activemq.store.kahadb.TempMessageDatabase)>(v);
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation: org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command> = v;
v.<org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation: org.apache.activemq.util.ByteSequence data> = v;
return;
}
public void execute(org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException
{
org.apache.activemq.store.kahadb.TempMessageDatabase v;
org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation v;
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation: org.apache.activemq.store.kahadb.TempMessageDatabase this$0>;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation: org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command>;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation: org.apache.activemq.util.ByteSequence data>;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void upadateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction,org.apache.activemq.store.kahadb.data.KahaAddMessageCommand,org.apache.activemq.util.ByteSequence)>(v, v, v);
return;
}
public org.apache.activemq.store.kahadb.data.KahaAddMessageCommand getCommand()
{
org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation v;
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand v;
v := @this: org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation;
v = v.<org.apache.activemq.store.kahadb.TempMessageDatabase$AddOpperation: org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command>;
return v;
}
}