public class org.apache.activemq.store.kahadb.TempKahaDBStore extends org.apache.activemq.store.kahadb.TempMessageDatabase implements org.apache.activemq.store.PersistenceAdapter, org.apache.activemq.broker.BrokerServiceAware
{
private final org.apache.activemq.wireformat.WireFormat wireFormat;
private org.apache.activemq.broker.BrokerService brokerService;
public void <init>()
{
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void <init>()>();
v = new org.apache.activemq.openwire.OpenWireFormat;
specialinvoke v.<org.apache.activemq.openwire.OpenWireFormat: void <init>()>();
v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.wireformat.WireFormat wireFormat> = v;
return;
}
public void setBrokerName(java.lang.String)
{
java.lang.String v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: java.lang.String;
return;
}
public void setUsageManager(org.apache.activemq.usage.SystemUsage)
{
org.apache.activemq.usage.SystemUsage v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.usage.SystemUsage;
return;
}
public org.apache.activemq.store.TransactionStore createTransactionStore() throws java.io.IOException
{
org.apache.activemq.store.kahadb.TempKahaDBStore v;
org.apache.activemq.store.kahadb.TempKahaDBStore$1 v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v = new org.apache.activemq.store.kahadb.TempKahaDBStore$1;
specialinvoke v.<org.apache.activemq.store.kahadb.TempKahaDBStore$1: void <init>(org.apache.activemq.store.kahadb.TempKahaDBStore)>(v);
return v;
}
java.lang.String subscriptionKey(java.lang.String, java.lang.String)
{
org.apache.activemq.store.kahadb.TempKahaDBStore v;
java.lang.String v, v, v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("\u0001:\u0001");
return v;
}
public org.apache.activemq.store.MessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue) throws java.io.IOException
{
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQQueue;
v = new org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore;
specialinvoke v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBMessageStore: void <init>(org.apache.activemq.store.kahadb.TempKahaDBStore,org.apache.activemq.command.ActiveMQDestination)>(v, v);
return v;
}
public org.apache.activemq.store.TopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic) throws java.io.IOException
{
org.apache.activemq.command.ActiveMQTopic v;
org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBTopicMessageStore v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
v = new org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBTopicMessageStore;
specialinvoke v.<org.apache.activemq.store.kahadb.TempKahaDBStore$KahaDBTopicMessageStore: void <init>(org.apache.activemq.store.kahadb.TempKahaDBStore,org.apache.activemq.command.ActiveMQTopic)>(v, v);
return v;
}
public void removeQueueMessageStore(org.apache.activemq.command.ActiveMQQueue)
{
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQQueue;
return;
}
public void removeTopicMessageStore(org.apache.activemq.command.ActiveMQTopic)
{
org.apache.activemq.command.ActiveMQTopic v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
return;
}
public void deleteAllMessages() throws java.io.IOException
{
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
return;
}
public java.util.Set getDestinations()
{
java.lang.Throwable v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
java.io.IOException v;
java.lang.RuntimeException v;
java.util.HashSet v;
org.apache.activemq.store.kahadb.TempKahaDBStore$2 v;
java.lang.Object v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: java.lang.Object indexMutex>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.TempKahaDBStore$2;
specialinvoke v.<org.apache.activemq.store.kahadb.TempKahaDBStore$2: void <init>(org.apache.activemq.store.kahadb.TempKahaDBStore,java.util.HashSet)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
}
public long getLastMessageBrokerSequenceId() throws java.io.IOException
{
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
return 0L;
}
public long size()
{
org.apache.activemq.store.kahadb.TempKahaDBStore v;
java.util.concurrent.atomic.AtomicBoolean v;
java.io.IOException v;
long v;
java.lang.RuntimeException v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: java.util.concurrent.atomic.AtomicBoolean started>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
return 0L;
label:
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: long getDiskSize()>();
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public void beginTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
java.io.IOException v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Not yet implemented.");
throw v;
}
public void commitTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
java.io.IOException v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Not yet implemented.");
throw v;
}
public void rollbackTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
java.io.IOException v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Not yet implemented.");
throw v;
}
public void checkpoint(boolean) throws java.io.IOException
{
boolean v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: boolean;
return;
}
org.apache.activemq.store.kahadb.data.KahaLocation convert(org.apache.activemq.store.kahadb.disk.journal.Location)
{
org.apache.activemq.store.kahadb.TempKahaDBStore v;
int v, v;
org.apache.activemq.store.kahadb.data.KahaLocation v;
org.apache.activemq.store.kahadb.disk.journal.Location v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location;
v = new org.apache.activemq.store.kahadb.data.KahaLocation;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaLocation: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Location: int getDataFileId()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaLocation: java.lang.Object setLogId(int)>(v);
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Location: int getOffset()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaLocation: java.lang.Object setOffset(int)>(v);
return v;
}
org.apache.activemq.store.kahadb.data.KahaDestination convert(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType v, v, v, v;
org.apache.activemq.store.kahadb.data.KahaDestination v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
org.apache.activemq.command.ActiveMQDestination v;
byte v;
java.lang.String v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = new org.apache.activemq.store.kahadb.data.KahaDestination;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: java.lang.Object setName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: byte getDestinationType()>();
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
default: goto label;
};
label:
v = <org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType QUEUE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: java.lang.Object setType(org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType)>(v);
return v;
label:
v = <org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType TOPIC>;
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: java.lang.Object setType(org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType)>(v);
return v;
label:
v = <org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType TEMP_QUEUE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: java.lang.Object setType(org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType)>(v);
return v;
label:
v = <org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType TEMP_TOPIC>;
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination: java.lang.Object setType(org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType)>(v);
return v;
label:
return null;
}
org.apache.activemq.command.ActiveMQDestination convert(java.lang.String)
{
org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType v;
org.apache.activemq.command.ActiveMQTempQueue v;
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.command.ActiveMQTempTopic v;
int[] v;
int v, v, v, v, v;
java.lang.String v, v, v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
java.lang.IllegalArgumentException v, v;
org.apache.activemq.command.ActiveMQTopic v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>(":");
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Not in the valid destination format");
throw v;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = <org.apache.activemq.store.kahadb.TempKahaDBStore$3: int[] $SwitchMap$org$apache$activemq$store$kahadb$data$KahaDestination$DestinationType>;
v = staticinvoke <org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType valueOf(int)>(v);
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
v = new org.apache.activemq.command.ActiveMQQueue;
specialinvoke v.<org.apache.activemq.command.ActiveMQQueue: void <init>(java.lang.String)>(v);
return v;
label:
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
label:
v = new org.apache.activemq.command.ActiveMQTempQueue;
specialinvoke v.<org.apache.activemq.command.ActiveMQTempQueue: void <init>(java.lang.String)>(v);
return v;
label:
v = new org.apache.activemq.command.ActiveMQTempTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTempTopic: void <init>(java.lang.String)>(v);
return v;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Not in the valid destination format");
throw v;
}
public long getLastProducerSequenceId(org.apache.activemq.command.ProducerId)
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.command.ProducerId;
return -1L;
}
public void allowIOResumption()
{
org.apache.activemq.store.kahadb.disk.page.PageFile v, v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void allowIOResumption()>();
label:
return;
}
public void setBrokerService(org.apache.activemq.broker.BrokerService)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v := @parameter: org.apache.activemq.broker.BrokerService;
v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.broker.BrokerService brokerService> = v;
return;
}
public void load() throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v, v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
org.apache.activemq.wireformat.WireFormat v;
int v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.broker.BrokerService brokerService>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.wireformat.WireFormat wireFormat>;
v = v.<org.apache.activemq.store.kahadb.TempKahaDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: int getStoreOpenWireVersion()>();
interfaceinvoke v.<org.apache.activemq.wireformat.WireFormat: void setVersion(int)>(v);
label:
specialinvoke v.<org.apache.activemq.store.kahadb.TempMessageDatabase: void load()>();
return;
}
public org.apache.activemq.broker.scheduler.JobSchedulerStore createJobSchedulerStore() throws java.io.IOException, java.lang.UnsupportedOperationException
{
java.lang.UnsupportedOperationException v;
org.apache.activemq.store.kahadb.TempKahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.TempKahaDBStore;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
}