public class org.apache.activemq.console.command.store.StoreExporter extends java.lang.Object
{
static final int OPENWIRE_VERSION;
static final boolean TIGHT_ENCODING;
java.net.URI config;
java.io.File file;
private final com.fasterxml.jackson.databind.ObjectMapper mapper;
private final org.fusesource.hawtbuf.AsciiBuffer ds_kind;
private final org.fusesource.hawtbuf.AsciiBuffer ptp_kind;
private final org.fusesource.hawtbuf.AsciiBuffer codec_id;
private final org.apache.activemq.openwire.OpenWireFormat wireformat;
public void <init>() throws java.net.URISyntaxException
{
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.activemq.openwire.OpenWireFormat v, v, v, v;
org.apache.activemq.console.command.store.StoreExporter v;
java.net.URI v;
org.fusesource.hawtbuf.AsciiBuffer v, v, v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v.<org.apache.activemq.console.command.store.StoreExporter: com.fasterxml.jackson.databind.ObjectMapper mapper> = v;
v = new org.fusesource.hawtbuf.AsciiBuffer;
specialinvoke v.<org.fusesource.hawtbuf.AsciiBuffer: void <init>(java.lang.String)>("ds");
v.<org.apache.activemq.console.command.store.StoreExporter: org.fusesource.hawtbuf.AsciiBuffer ds_kind> = v;
v = new org.fusesource.hawtbuf.AsciiBuffer;
specialinvoke v.<org.fusesource.hawtbuf.AsciiBuffer: void <init>(java.lang.String)>("ptp");
v.<org.apache.activemq.console.command.store.StoreExporter: org.fusesource.hawtbuf.AsciiBuffer ptp_kind> = v;
v = new org.fusesource.hawtbuf.AsciiBuffer;
specialinvoke v.<org.fusesource.hawtbuf.AsciiBuffer: void <init>(java.lang.String)>("openwire");
v.<org.apache.activemq.console.command.store.StoreExporter: org.fusesource.hawtbuf.AsciiBuffer codec_id> = v;
v = new org.apache.activemq.openwire.OpenWireFormat;
specialinvoke v.<org.apache.activemq.openwire.OpenWireFormat: void <init>()>();
v.<org.apache.activemq.console.command.store.StoreExporter: org.apache.activemq.openwire.OpenWireFormat wireformat> = v;
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>("xbean:activemq.xml");
v.<org.apache.activemq.console.command.store.StoreExporter: java.net.URI config> = v;
v = v.<org.apache.activemq.console.command.store.StoreExporter: org.apache.activemq.openwire.OpenWireFormat wireformat>;
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormat: void setCacheEnabled(boolean)>(0);
v = v.<org.apache.activemq.console.command.store.StoreExporter: org.apache.activemq.openwire.OpenWireFormat wireformat>;
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormat: void setTightEncodingEnabled(boolean)>(0);
v = v.<org.apache.activemq.console.command.store.StoreExporter: org.apache.activemq.openwire.OpenWireFormat wireformat>;
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormat: void setVersion(int)>(8);
return;
}
public void execute() throws java.lang.Exception
{
java.lang.Throwable v, v;
java.io.BufferedOutputStream v;
java.lang.String v, v;
java.net.URI v, v, v;
java.io.PrintStream v, v;
org.apache.activemq.broker.BrokerService v;
java.io.FileOutputStream v;
java.io.File v, v;
java.lang.Exception v, v;
org.apache.activemq.console.command.store.StoreExporter v;
org.apache.activemq.store.PersistenceAdapter v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v = v.<org.apache.activemq.console.command.store.StoreExporter: java.net.URI config>;
if v != null goto label;
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("required --config option missing");
throw v;
label:
v = v.<org.apache.activemq.console.command.store.StoreExporter: java.io.File file>;
if v != null goto label;
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("required --file option missing");
throw v;
label:
v = <java.lang.System: java.io.PrintStream out>;
v = v.<org.apache.activemq.console.command.store.StoreExporter: java.net.URI config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.net.URI)>(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[])>("Loading: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
staticinvoke <org.apache.activemq.broker.BrokerFactory: void setStartDefault(boolean)>(0);
v = v.<org.apache.activemq.console.command.store.StoreExporter: java.net.URI config>;
v = staticinvoke <org.apache.activemq.broker.BrokerFactory: org.apache.activemq.broker.BrokerService createBroker(java.net.URI)>(v);
staticinvoke <org.apache.activemq.broker.BrokerFactory: void resetStartDefault()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
v = <java.lang.System: java.io.PrintStream out>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.store.PersistenceAdapter)>(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[])>("Starting: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void start()>();
label:
v = new java.io.BufferedOutputStream;
v = new java.io.FileOutputStream;
v = v.<org.apache.activemq.console.command.store.StoreExporter: java.io.File file>;
specialinvoke v.<java.io.FileOutputStream: void <init>(java.io.File)>(v);
specialinvoke v.<java.io.BufferedOutputStream: void <init>(java.io.OutputStream)>(v);
label:
virtualinvoke v.<org.apache.activemq.console.command.store.StoreExporter: void export(org.apache.activemq.store.PersistenceAdapter,java.io.BufferedOutputStream)>(v, v);
label:
virtualinvoke v.<java.io.BufferedOutputStream: void close()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.io.BufferedOutputStream: void close()>();
throw v;
label:
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void stop()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void stop()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
void export(org.apache.activemq.store.PersistenceAdapter, java.io.BufferedOutputStream) throws java.lang.Exception
{
org.apache.activemq.console.command.store.StoreExporter$3 v;
org.apache.activemq.console.command.store.StoreExporter$1 v;
int[] v;
org.apache.activemq.console.command.store.StoreExporter$2 v;
boolean v, v, v, v;
java.util.Set v;
java.lang.Exception v;
org.apache.activemq.command.ActiveMQDestination v;
java.lang.Object[] v;
java.util.HashMap v, v, v;
long v, v, v, v;
java.io.BufferedOutputStream v;
long[] v, v, v, v;
int v, v, v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.store.TransactionStore v;
java.io.PrintStream v, v;
org.apache.activemq.store.MessageStore v;
org.apache.activemq.command.SubscriptionInfo v;
java.util.Iterator v;
com.fasterxml.jackson.databind.ObjectMapper v, v;
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.console.command.store.StoreExporter v;
org.apache.activemq.command.SubscriptionInfo[] v;
org.apache.activemq.console.command.store.ExportStreamManager v;
org.apache.activemq.console.command.store.proto.QueuePB$Bean v, v;
org.fusesource.hawtbuf.UTF8Buffer v, v;
java.lang.Object v;
org.apache.activemq.store.PersistenceAdapter v;
org.fusesource.hawtbuf.AsciiBuffer v, v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v := @parameter: org.apache.activemq.store.PersistenceAdapter;
v := @parameter: java.io.BufferedOutputStream;
v = newarray (long)[1];
v[0] = 0L;
v = newarray (long)[1];
v[0] = 0L;
v = new org.apache.activemq.console.command.store.ExportStreamManager;
specialinvoke v.<org.apache.activemq.console.command.store.ExportStreamManager: void <init>(java.io.OutputStream,int)>(v, 1);
v = newarray (int)[1];
v[0] = 0;
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: org.apache.activemq.store.TransactionStore createTransactionStore()>();
v = new org.apache.activemq.console.command.store.StoreExporter$1;
specialinvoke v.<org.apache.activemq.console.command.store.StoreExporter$1: void <init>(org.apache.activemq.console.command.store.StoreExporter,int[])>(v, v);
interfaceinvoke v.<org.apache.activemq.store.TransactionStore: void recover(org.apache.activemq.store.TransactionRecoveryListener)>(v);
v = v[0];
if v <= 0 goto label;
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Cannot export a store with prepared XA transactions.  Please commit or rollback those transactions before attempting to export.");
throw v;
label:
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: java.util.Set getDestinations()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v[0];
v = v + 1L;
v[0] = v;
v = v instanceof org.apache.activemq.command.ActiveMQQueue;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: org.apache.activemq.store.MessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue)>(v);
v = new org.apache.activemq.console.command.store.proto.QueuePB$Bean;
specialinvoke v.<org.apache.activemq.console.command.store.proto.QueuePB$Bean: void <init>()>();
v = v[0];
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueuePB$Bean: org.apache.activemq.console.command.store.proto.QueuePB$Bean setKey(long)>(v);
v = v.<org.apache.activemq.console.command.store.StoreExporter: org.fusesource.hawtbuf.AsciiBuffer ptp_kind>;
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueuePB$Bean: org.apache.activemq.console.command.store.proto.QueuePB$Bean setBindingKind(org.fusesource.hawtbuf.AsciiBuffer)>(v);
v = newarray (long)[1];
v[0] = 0L;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("@class", "queue_destination");
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQQueue: java.lang.String getQueueName()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("name", v);
v = v.<org.apache.activemq.console.command.store.StoreExporter: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>(v);
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = new org.fusesource.hawtbuf.UTF8Buffer;
specialinvoke v.<org.fusesource.hawtbuf.UTF8Buffer: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueuePB$Bean: org.apache.activemq.console.command.store.proto.QueuePB$Bean setBindingData(org.fusesource.hawtbuf.Buffer)>(v);
virtualinvoke v.<org.apache.activemq.console.command.store.ExportStreamManager: void store_queue(org.apache.activemq.console.command.store.proto.QueuePB$Getter)>(v);
v = new org.apache.activemq.console.command.store.StoreExporter$2;
specialinvoke v.<org.apache.activemq.console.command.store.StoreExporter$2: void <init>(org.apache.activemq.console.command.store.StoreExporter,long[],long[],org.apache.activemq.console.command.store.ExportStreamManager,long[])>(v, v, v, v, v);
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void recover(org.apache.activemq.store.MessageRecoveryListener)>(v);
goto label;
label:
v = v instanceof org.apache.activemq.command.ActiveMQTopic;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: org.apache.activemq.store.TopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic)>(v);
v = interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: org.apache.activemq.command.SubscriptionInfo[] getAllSubscriptions()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = new org.apache.activemq.console.command.store.proto.QueuePB$Bean;
specialinvoke v.<org.apache.activemq.console.command.store.proto.QueuePB$Bean: void <init>()>();
v = v[0];
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueuePB$Bean: org.apache.activemq.console.command.store.proto.QueuePB$Bean setKey(long)>(v);
v = v.<org.apache.activemq.console.command.store.StoreExporter: org.fusesource.hawtbuf.AsciiBuffer ds_kind>;
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueuePB$Bean: org.apache.activemq.console.command.store.proto.QueuePB$Bean setBindingKind(org.fusesource.hawtbuf.AsciiBuffer)>(v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("@class", "dsub_destination");
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getClientId()>();
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getSubscriptionName()>();
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");
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("name", v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTopic: java.lang.String getTopicName()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("name", v);
v = newarray (java.lang.Object)[1];
v[0] = v;
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("topics", v);
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getSelector()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getSelector()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("selector", v);
label:
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: boolean isNoLocal()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("noLocal", v);
v = v.<org.apache.activemq.console.command.store.StoreExporter: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>(v);
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = new org.fusesource.hawtbuf.UTF8Buffer;
specialinvoke v.<org.fusesource.hawtbuf.UTF8Buffer: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueuePB$Bean: org.apache.activemq.console.command.store.proto.QueuePB$Bean setBindingData(org.fusesource.hawtbuf.Buffer)>(v);
virtualinvoke v.<org.apache.activemq.console.command.store.ExportStreamManager: void store_queue(org.apache.activemq.console.command.store.proto.QueuePB$Getter)>(v);
v = newarray (long)[1];
v[0] = 0L;
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getClientId()>();
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getSubscriptionName()>();
v = new org.apache.activemq.console.command.store.StoreExporter$3;
specialinvoke v.<org.apache.activemq.console.command.store.StoreExporter$3: void <init>(org.apache.activemq.console.command.store.StoreExporter,long[],long[],org.apache.activemq.console.command.store.ExportStreamManager,long[])>(v, v, v, v, v);
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void recoverSubscription(java.lang.String,java.lang.String,org.apache.activemq.store.MessageRecoveryListener)>(v, v, v);
v = v + 1;
goto label;
label:
virtualinvoke v.<org.apache.activemq.console.command.store.ExportStreamManager: void finish()>();
return;
}
private org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean createQueueEntryPB(org.apache.activemq.command.Message, long, long, long)
{
long v, v, v, v, v;
org.apache.activemq.command.Message v;
byte v;
org.apache.activemq.console.command.store.StoreExporter v;
int v, v, v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = new org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean;
specialinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: void <init>()>();
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean setQueueKey(long)>(v);
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean setQueueSeq(long)>(v);
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean setMessageKey(long)>(v);
v = virtualinvoke v.<org.apache.activemq.command.Message: int getSize()>();
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean setSize(int)>(v);
v = virtualinvoke v.<org.apache.activemq.command.Message: long getExpiration()>();
v = v cmp 0L;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: long getExpiration()>();
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean setExpiration(long)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.Message: int getRedeliveryCounter()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: int getRedeliveryCounter()>();
virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean setRedeliveries(int)>(v);
label:
return v;
}
private org.apache.activemq.console.command.store.proto.MessagePB$Bean createMessagePB(org.apache.activemq.command.Message, long) throws java.io.IOException
{
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
long v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.command.Message v;
org.apache.activemq.console.command.store.proto.MessagePB$Bean v;
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.console.command.store.StoreExporter v;
int v;
org.fusesource.hawtbuf.AsciiBuffer v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: long;
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>()>();
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeBoolean(boolean)>(0);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeVarInt(int)>(8);
v = v.<org.apache.activemq.console.command.store.StoreExporter: org.apache.activemq.openwire.OpenWireFormat wireformat>;
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormat: void marshal(java.lang.Object,java.io.DataOutput)>(v, v);
v = new org.apache.activemq.console.command.store.proto.MessagePB$Bean;
specialinvoke v.<org.apache.activemq.console.command.store.proto.MessagePB$Bean: void <init>()>();
v = v.<org.apache.activemq.console.command.store.StoreExporter: org.fusesource.hawtbuf.AsciiBuffer codec_id>;
virtualinvoke v.<org.apache.activemq.console.command.store.proto.MessagePB$Bean: org.apache.activemq.console.command.store.proto.MessagePB$Bean setCodec(org.fusesource.hawtbuf.AsciiBuffer)>(v);
virtualinvoke v.<org.apache.activemq.console.command.store.proto.MessagePB$Bean: org.apache.activemq.console.command.store.proto.MessagePB$Bean setMessageKey(long)>(v);
v = virtualinvoke v.<org.apache.activemq.command.Message: int getSize()>();
virtualinvoke v.<org.apache.activemq.console.command.store.proto.MessagePB$Bean: org.apache.activemq.console.command.store.proto.MessagePB$Bean setSize(int)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: org.fusesource.hawtbuf.Buffer toBuffer()>();
virtualinvoke v.<org.apache.activemq.console.command.store.proto.MessagePB$Bean: org.apache.activemq.console.command.store.proto.MessagePB$Bean setValue(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public java.io.File getFile()
{
org.apache.activemq.console.command.store.StoreExporter v;
java.io.File v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v = v.<org.apache.activemq.console.command.store.StoreExporter: java.io.File file>;
return v;
}
public void setFile(java.lang.String)
{
java.lang.String v;
org.apache.activemq.console.command.store.StoreExporter v;
java.io.File v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v := @parameter: java.lang.String;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.console.command.store.StoreExporter: void setFile(java.io.File)>(v);
return;
}
public void setFile(java.io.File)
{
org.apache.activemq.console.command.store.StoreExporter v;
java.io.File v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v := @parameter: java.io.File;
v.<org.apache.activemq.console.command.store.StoreExporter: java.io.File file> = v;
return;
}
public java.net.URI getConfig()
{
java.net.URI v;
org.apache.activemq.console.command.store.StoreExporter v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v = v.<org.apache.activemq.console.command.store.StoreExporter: java.net.URI config>;
return v;
}
public void setConfig(java.net.URI)
{
java.net.URI v;
org.apache.activemq.console.command.store.StoreExporter v;
v := @this: org.apache.activemq.console.command.store.StoreExporter;
v := @parameter: java.net.URI;
v.<org.apache.activemq.console.command.store.StoreExporter: java.net.URI config> = v;
return;
}
}