public class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter extends org.apache.activemq.broker.LockableServiceSupport implements org.apache.activemq.store.PersistenceAdapter, org.apache.activemq.store.JournaledStore, org.apache.activemq.store.TransactionIdTransformerAware, org.apache.activemq.store.NoLocalSubscriptionAware
{
private final org.apache.activemq.store.kahadb.KahaDBStore letter;
public void <init>()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
specialinvoke v.<org.apache.activemq.broker.LockableServiceSupport: void <init>()>();
v = new org.apache.activemq.store.kahadb.KahaDBStore;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void <init>()>();
v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter> = v;
return;
}
public void beginTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void beginTransaction(org.apache.activemq.broker.ConnectionContext)>(v);
return;
}
public void checkpoint(boolean) throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void checkpoint(boolean)>(v);
return;
}
public void commitTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void commitTransaction(org.apache.activemq.broker.ConnectionContext)>(v);
return;
}
public org.apache.activemq.store.MessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.command.ActiveMQQueue;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.MessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue)>(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.TopicMessageStore v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.TopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic)>(v);
return v;
}
public org.apache.activemq.store.TransactionStore createTransactionStore() throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
org.apache.activemq.store.TransactionStore v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.TransactionStore createTransactionStore()>();
return v;
}
public void deleteAllMessages() throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void deleteAllMessages()>();
return;
}
public java.util.Set getDestinations()
{
java.util.Set v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: java.util.Set getDestinations()>();
return v;
}
public long getLastMessageBrokerSequenceId() throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBStore v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: long getLastMessageBrokerSequenceId()>();
return v;
}
public long getLastProducerSequenceId(org.apache.activemq.command.ProducerId) throws java.io.IOException
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.store.kahadb.KahaDBStore v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.command.ProducerId;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: long getLastProducerSequenceId(org.apache.activemq.command.ProducerId)>(v);
return v;
}
public void allowIOResumption()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void allowIOResumption()>();
return;
}
public void removeQueueMessageStore(org.apache.activemq.command.ActiveMQQueue)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.command.ActiveMQQueue;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void removeQueueMessageStore(org.apache.activemq.command.ActiveMQQueue)>(v);
return;
}
public void removeTopicMessageStore(org.apache.activemq.command.ActiveMQTopic)
{
org.apache.activemq.command.ActiveMQTopic v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void removeTopicMessageStore(org.apache.activemq.command.ActiveMQTopic)>(v);
return;
}
public void rollbackTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void rollbackTransaction(org.apache.activemq.broker.ConnectionContext)>(v);
return;
}
public void setBrokerName(java.lang.String)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setBrokerName(java.lang.String)>(v);
return;
}
public void setUsageManager(org.apache.activemq.usage.SystemUsage)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.usage.SystemUsage v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.usage.SystemUsage;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setUsageManager(org.apache.activemq.usage.SystemUsage)>(v);
return;
}
public long size()
{
org.apache.activemq.store.kahadb.KahaDBStore v, v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isStarted()>();
if v == 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: long size()>();
goto label;
label:
v = 0L;
label:
return v;
}
public void doStart() throws java.lang.Exception
{
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.broker.jmx.PersistenceAdapterView v;
java.lang.String v, v;
boolean v;
org.apache.activemq.broker.BrokerService v, v, v, v;
org.apache.activemq.store.PersistenceAdapterStatistics v;
javax.management.ObjectName v, v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter$1 v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter$2 v;
org.apache.activemq.store.kahadb.KahaDBStore v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void start()>();
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.BrokerService brokerService>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.jmx.PersistenceAdapterView;
specialinvoke v.<org.apache.activemq.broker.jmx.PersistenceAdapterView: void <init>(org.apache.activemq.store.PersistenceAdapter)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter$1;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter$1: void <init>(org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter)>(v);
virtualinvoke v.<org.apache.activemq.broker.jmx.PersistenceAdapterView: void setInflightTransactionViewCallable(java.util.concurrent.Callable)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter$2;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter$2: void <init>(org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter)>(v);
virtualinvoke v.<org.apache.activemq.broker.jmx.PersistenceAdapterView: void setDataViewCallable(java.util.concurrent.Callable)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.PersistenceAdapterStatistics persistenceAdapterStatistics>;
virtualinvoke v.<org.apache.activemq.broker.jmx.PersistenceAdapterView: void setPersistenceAdapterStatistics(org.apache.activemq.store.PersistenceAdapterStatistics)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: java.lang.String toString()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createPersistenceAdapterName(java.lang.String,java.lang.String)>(v, v);
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
return;
}
public void doStop(org.apache.activemq.util.ServiceStopper) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v, v, v, v;
javax.management.ObjectName v, v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
org.apache.activemq.util.ServiceStopper v;
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.util.ServiceStopper;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void stop()>();
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.BrokerService brokerService>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: java.lang.String toString()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createPersistenceAdapterName(java.lang.String,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void unregisterMBean(javax.management.ObjectName)>(v);
label:
return;
}
public int getJournalMaxFileLength()
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: int getJournalMaxFileLength()>();
return v;
}
public void setJournalMaxFileLength(int)
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setJournalMaxFileLength(int)>(v);
return;
}
public void setMaxFailoverProducersToTrack(int)
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setMaxFailoverProducersToTrack(int)>(v);
return;
}
public int getMaxFailoverProducersToTrack()
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: int getMaxFailoverProducersToTrack()>();
return v;
}
public void setFailoverProducersAuditDepth(int)
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setFailoverProducersAuditDepth(int)>(v);
return;
}
public int getFailoverProducersAuditDepth()
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: int getFailoverProducersAuditDepth()>();
return v;
}
public long getCheckpointInterval()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: long getCheckpointInterval()>();
return v;
}
public void setCheckpointInterval(long)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: long;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setCheckpointInterval(long)>(v);
return;
}
public long getCleanupInterval()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: long getCleanupInterval()>();
return v;
}
public void setCleanupInterval(long)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: long;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setCleanupInterval(long)>(v);
return;
}
public int getIndexWriteBatchSize()
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: int getIndexWriteBatchSize()>();
return v;
}
public void setIndexWriteBatchSize(int)
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setIndexWriteBatchSize(int)>(v);
return;
}
public int getJournalMaxWriteBatchSize()
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: int getJournalMaxWriteBatchSize()>();
return v;
}
public void setJournalMaxWriteBatchSize(int)
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setJournalMaxWriteBatchSize(int)>(v);
return;
}
public boolean isEnableIndexWriteAsync()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableIndexWriteAsync()>();
return v;
}
public void setEnableIndexWriteAsync(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setEnableIndexWriteAsync(boolean)>(v);
return;
}
public org.apache.activemq.store.PersistenceAdapterStatistics getPersistenceAdapterStatistics()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
org.apache.activemq.store.PersistenceAdapterStatistics v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.PersistenceAdapterStatistics getPersistenceAdapterStatistics()>();
return v;
}
public java.io.File getDirectory()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: java.io.File getDirectory()>();
return v;
}
public void setDirectory(java.io.File)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: java.io.File;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setDirectory(java.io.File)>(v);
return;
}
public java.io.File getIndexDirectory()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: java.io.File getIndexDirectory()>();
return v;
}
public void setIndexDirectory(java.io.File)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: java.io.File;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setIndexDirectory(java.io.File)>(v);
return;
}
public boolean isEnableJournalDiskSyncs()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableJournalDiskSyncs()>();
return v;
}
public void setEnableJournalDiskSyncs(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setEnableJournalDiskSyncs(boolean)>(v);
return;
}
public java.lang.String getJournalDiskSyncStrategy()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: java.lang.String getJournalDiskSyncStrategy()>();
return v;
}
public org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy getJournalDiskSyncStrategyEnum()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy getJournalDiskSyncStrategyEnum()>();
return v;
}
public void setJournalDiskSyncStrategy(java.lang.String)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setJournalDiskSyncStrategy(java.lang.String)>(v);
return;
}
public long getJournalDiskSyncInterval()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: long getJournalDiskSyncInterval()>();
return v;
}
public void setJournalDiskSyncInterval(long)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: long;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setJournalDiskSyncInterval(long)>(v);
return;
}
public int getIndexCacheSize()
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: int getIndexCacheSize()>();
return v;
}
public void setIndexCacheSize(int)
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setIndexCacheSize(int)>(v);
return;
}
public boolean isIgnoreMissingJournalfiles()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isIgnoreMissingJournalfiles()>();
return v;
}
public void setIgnoreMissingJournalfiles(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setIgnoreMissingJournalfiles(boolean)>(v);
return;
}
public boolean isChecksumJournalFiles()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isChecksumJournalFiles()>();
return v;
}
public boolean isCheckForCorruptJournalFiles()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isCheckForCorruptJournalFiles()>();
return v;
}
public void setChecksumJournalFiles(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setChecksumJournalFiles(boolean)>(v);
return;
}
public void setCheckForCorruptJournalFiles(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setCheckForCorruptJournalFiles(boolean)>(v);
return;
}
public java.lang.String getPurgeRecoveredXATransactionStrategy()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: java.lang.String getPurgeRecoveredXATransactionStrategy()>();
return v;
}
public void setPurgeRecoveredXATransactionStrategy(java.lang.String)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setPurgeRecoveredXATransactionStrategy(java.lang.String)>(v);
return;
}
public void setBrokerService(org.apache.activemq.broker.BrokerService)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.broker.BrokerService;
specialinvoke v.<org.apache.activemq.broker.LockableServiceSupport: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
return;
}
public java.lang.String getPreallocationScope()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: java.lang.String getPreallocationScope()>();
return v;
}
public void setPreallocationScope(java.lang.String)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setPreallocationScope(java.lang.String)>(v);
return;
}
public java.lang.String getPreallocationStrategy()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: java.lang.String getPreallocationStrategy()>();
return v;
}
public void setPreallocationStrategy(java.lang.String)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setPreallocationStrategy(java.lang.String)>(v);
return;
}
public boolean isArchiveDataLogs()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isArchiveDataLogs()>();
return v;
}
public void setArchiveDataLogs(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setArchiveDataLogs(boolean)>(v);
return;
}
public java.io.File getDirectoryArchive()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: java.io.File getDirectoryArchive()>();
return v;
}
public void setDirectoryArchive(java.io.File)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: java.io.File;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setDirectoryArchive(java.io.File)>(v);
return;
}
public boolean isConcurrentStoreAndDispatchQueues()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchQueues()>();
return v;
}
public void setConcurrentStoreAndDispatchQueues(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setConcurrentStoreAndDispatchQueues(boolean)>(v);
return;
}
public boolean isConcurrentStoreAndDispatchTopics()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTopics()>();
return v;
}
public void setConcurrentStoreAndDispatchTopics(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setConcurrentStoreAndDispatchTopics(boolean)>(v);
return;
}
public int getMaxAsyncJobs()
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: int getMaxAsyncJobs()>();
return v;
}
public void setMaxAsyncJobs(int)
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setMaxAsyncJobs(int)>(v);
return;
}
public void setDatabaseLockedWaitDelay(int) throws java.io.IOException
{
int v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
org.apache.activemq.broker.Locker v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.broker.Locker getLocker()>();
interfaceinvoke v.<org.apache.activemq.broker.Locker: void setLockAcquireSleepInterval(long)>(v);
return;
}
public boolean getForceRecoverIndex()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean getForceRecoverIndex()>();
return v;
}
public void setForceRecoverIndex(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setForceRecoverIndex(boolean)>(v);
return;
}
public boolean isArchiveCorruptedIndex()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isArchiveCorruptedIndex()>();
return v;
}
public void setArchiveCorruptedIndex(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setArchiveCorruptedIndex(boolean)>(v);
return;
}
public float getIndexLFUEvictionFactor()
{
float v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: float getIndexLFUEvictionFactor()>();
return v;
}
public void setIndexLFUEvictionFactor(float)
{
float v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: float;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setIndexLFUEvictionFactor(float)>(v);
return;
}
public boolean isUseIndexLFRUEviction()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isUseIndexLFRUEviction()>();
return v;
}
public void setUseIndexLFRUEviction(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setUseIndexLFRUEviction(boolean)>(v);
return;
}
public void setEnableIndexDiskSyncs(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setEnableIndexDiskSyncs(boolean)>(v);
return;
}
public boolean isEnableIndexDiskSyncs()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableIndexDiskSyncs()>();
return v;
}
public void setEnableIndexRecoveryFile(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setEnableIndexRecoveryFile(boolean)>(v);
return;
}
public boolean isEnableIndexRecoveryFile()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableIndexRecoveryFile()>();
return v;
}
public void setEnableIndexPageCaching(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setEnableIndexPageCaching(boolean)>(v);
return;
}
public boolean isEnableIndexPageCaching()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableIndexPageCaching()>();
return v;
}
public int getCompactAcksAfterNoGC()
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: int getCompactAcksAfterNoGC()>();
return v;
}
public void setCompactAcksAfterNoGC(int)
{
int v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: int;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setCompactAcksAfterNoGC(int)>(v);
return;
}
public boolean isCompactAcksIgnoresStoreGrowth()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isCompactAcksIgnoresStoreGrowth()>();
return v;
}
public void setCompactAcksIgnoresStoreGrowth(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setCompactAcksIgnoresStoreGrowth(boolean)>(v);
return;
}
public boolean isEnableAckCompaction()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableAckCompaction()>();
return v;
}
public void setEnableAckCompaction(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setEnableAckCompaction(boolean)>(v);
return;
}
public boolean isEnableSubscriptionStatistics()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableSubscriptionStatistics()>();
return v;
}
public void setEnableSubscriptionStatistics(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setEnableSubscriptionStatistics(boolean)>(v);
return;
}
public org.apache.activemq.store.kahadb.KahaDBStore getStore()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
return v;
}
public org.apache.activemq.store.kahadb.data.KahaTransactionInfo createTransactionInfo(org.apache.activemq.command.TransactionId)
{
byte[] v, v;
org.apache.activemq.store.kahadb.data.KahaTransactionInfo v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.protobuf.Buffer v, v;
long v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
int v;
org.apache.activemq.store.kahadb.data.KahaXATransactionId v;
org.apache.activemq.store.kahadb.data.KahaLocalTransactionId v;
java.lang.String v;
org.apache.activemq.command.TransactionId v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.command.TransactionId;
if v != null goto label;
return null;
label:
v = new org.apache.activemq.store.kahadb.data.KahaTransactionInfo;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaTransactionInfo: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isLocalTransaction()>();
if v == 0 goto label;
v = new org.apache.activemq.store.kahadb.data.KahaLocalTransactionId;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaLocalTransactionId: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.command.LocalTransactionId: org.apache.activemq.command.ConnectionId getConnectionId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConnectionId: java.lang.String getValue()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaLocalTransactionId: java.lang.Object setConnectionId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.command.LocalTransactionId: long getValue()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaLocalTransactionId: java.lang.Object setTransactionId(long)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaTransactionInfo: java.lang.Object setLocalTransactionId(org.apache.activemq.store.kahadb.data.KahaLocalTransactionId)>(v);
goto label;
label:
v = new org.apache.activemq.store.kahadb.data.KahaXATransactionId;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaXATransactionId: void <init>()>();
v = new org.apache.activemq.protobuf.Buffer;
v = virtualinvoke v.<org.apache.activemq.command.XATransactionId: byte[] getBranchQualifier()>();
specialinvoke v.<org.apache.activemq.protobuf.Buffer: void <init>(byte[])>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaXATransactionId: java.lang.Object setBranchQualifier(org.apache.activemq.protobuf.Buffer)>(v);
v = new org.apache.activemq.protobuf.Buffer;
v = virtualinvoke v.<org.apache.activemq.command.XATransactionId: byte[] getGlobalTransactionId()>();
specialinvoke v.<org.apache.activemq.protobuf.Buffer: void <init>(byte[])>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaXATransactionId: java.lang.Object setGlobalTransactionId(org.apache.activemq.protobuf.Buffer)>(v);
v = virtualinvoke v.<org.apache.activemq.command.XATransactionId: int getFormatId()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaXATransactionId: java.lang.Object setFormatId(int)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaTransactionInfo: java.lang.Object setXaTransactionId(org.apache.activemq.store.kahadb.data.KahaXATransactionId)>(v);
label:
return v;
}
public org.apache.activemq.broker.Locker createDefaultLocker() throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
org.apache.activemq.store.SharedFileLocker v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = new org.apache.activemq.store.SharedFileLocker;
specialinvoke v.<org.apache.activemq.store.SharedFileLocker: void <init>()>();
virtualinvoke v.<org.apache.activemq.store.SharedFileLocker: void configure(org.apache.activemq.store.PersistenceAdapter)>(v);
return v;
}
public void init() throws java.lang.Exception
{
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
return;
}
public java.lang.String toString()
{
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
java.io.File v, v, v, v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: java.io.File getDirectory()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: java.io.File getDirectory()>();
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
goto label;
label:
v = "DIRECTORY_NOT_SET";
label:
v = v;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: java.io.File getIndexDirectory()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: java.io.File getIndexDirectory()>();
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>(",Index:\u0001");
goto label;
label:
v = "";
label:
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[])>("KahaDBPersistenceAdapter[\u0001\u]");
return v;
}
public void setTransactionIdTransformer(org.apache.activemq.store.TransactionIdTransformer)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: org.apache.activemq.store.TransactionIdTransformer;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore getStore()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setTransactionIdTransformer(org.apache.activemq.store.TransactionIdTransformer)>(v);
return;
}
public org.apache.activemq.broker.scheduler.JobSchedulerStore createJobSchedulerStore() throws java.io.IOException, java.lang.UnsupportedOperationException
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.broker.scheduler.JobSchedulerStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.broker.scheduler.JobSchedulerStore createJobSchedulerStore()>();
return v;
}
public boolean isPersistNoLocal()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isPersistNoLocal()>();
return v;
}
public void setCleanupOnStop(boolean)
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void setCleanupOnStop(boolean)>(v);
return;
}
public boolean getCleanupOnStop()
{
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
v = v.<org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter: org.apache.activemq.store.kahadb.KahaDBStore letter>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean getCleanupOnStop()>();
return v;
}
}