public class org.apache.activemq.console.command.QueryCommand extends org.apache.activemq.console.command.AbstractJmxCommand
{
private static final java.util.Properties PREDEFINED_OBJNAME_QUERY;
protected java.lang.String[] helpFile;
private final java.util.List queryAddObjects;
private final java.util.List querySubObjects;
private final java.util.Set queryViews;
private final java.util.List opAndParams;
public void <init>()
{
java.lang.String[] v;
org.apache.activemq.console.command.QueryCommand v;
java.util.LinkedHashSet v;
java.util.ArrayList v, v, v;
v := @this: org.apache.activemq.console.command.QueryCommand;
specialinvoke v.<org.apache.activemq.console.command.AbstractJmxCommand: void <init>()>();
v = newarray (java.lang.String)[57];
v[0] = "Task Usage: Main query [query-options]";
v[1] = "Description: Display selected broker component\'s attributes and statistics.";
v[2] = "";
v[3] = "Query Options:";
v[4] = "    -Q<type>=<name>               Add to the search list the specific object type matched";
v[5] = "                                  by the defined object identifier.";
v[6] = "    -xQ<type>=<name>              Remove from the search list the specific object type";
v[7] = "                                  matched by the object identifier.";
v[8] = "    --objname <query>             Add to the search list objects matched by the query similar";
v[9] = "                                  to the JMX object name format.";
v[10] = "    --xobjname <query>            Remove from the search list objects matched by the query";
v[11] = "                                  similar to the JMX object name format.";
v[12] = "    --view <attr1>,<attr2>,...    Select the specific attribute of the object to view.";
v[13] = "                                  By default all attributes will be displayed.";
v[14] = "    --invoke <operation>          Specify the operation to invoke on matching objects";
v[15] = "    --jmxurl <url>                Set the JMX URL to connect to.";
v[16] = "    --pid <pid>                   Set the pid to connect to (only on Sun JVM).";
v[17] = "    --jmxuser <user>              Set the JMX user used for authenticating.";
v[18] = "    --jmxpassword <password>      Set the JMX password used for authenticating.";
v[19] = "    --jmxlocal                    Use the local JMX server instead of a remote one.";
v[20] = "    --version                     Display the version information.";
v[21] = "    -h,-?,--help                  Display the query broker help information.";
v[22] = "";
v[23] = "Examples:";
v[24] = "    query";
v[25] = "        - Print all the attributes of all registered objects queues, topics, connections, etc).";
v[26] = "";
v[27] = "    query -QQueue=TEST.FOO";
v[28] = "        - Print all the attributes of the queue with destination name TEST.FOO.";
v[29] = "";
v[30] = "    query -QTopic=*";
v[31] = "        - Print all the attributes of all registered topics.";
v[32] = "";
v[33] = "    query --view EnqueueCount,DequeueCount";
v[34] = "        - Print the attributes EnqueueCount and DequeueCount of all registered objects.";
v[35] = "";
v[36] = "    query -QTopic=* --view EnqueueCount,DequeueCount";
v[37] = "        - Print the attributes EnqueueCount and DequeueCount of all registered topics.";
v[38] = "";
v[39] = "    query -QTopic=* -QQueue=* --view EnqueueCount,DequeueCount";
v[40] = "        - Print the attributes EnqueueCount and DequeueCount of all registered topics and";
v[41] = "          queues.";
v[42] = "";
v[43] = "    query -QTopic=* -xQTopic=ActiveMQ.Advisory.*";
v[44] = "        - Print all attributes of all topics except those that has a name that begins";
v[45] = "          with \"ActiveMQ.Advisory\".";
v[46] = "";
v[47] = "    query --objname type=Broker,brokerName=*,connector=clientConnectors,connectorName=* -xQNetworkConnector=*";
v[48] = "        - Print all attributes of all connectors, connections excluding network connectors";
v[49] = "          that belongs to the broker that begins with local.";
v[50] = "";
v[51] = "    query -QQueue=* -xQQueue=????";
v[52] = "        - Print all attributes of all queues except those that are 4 letters long.";
v[53] = "";
v[54] = "    query -QQueue=* --invoke pause";
v[55] = "        - Pause all queues.";
v[56] = "";
v.<org.apache.activemq.console.command.QueryCommand: java.lang.String[] helpFile> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(10);
v.<org.apache.activemq.console.command.QueryCommand: java.util.List queryAddObjects> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(10);
v.<org.apache.activemq.console.command.QueryCommand: java.util.List querySubObjects> = v;
v = new java.util.LinkedHashSet;
specialinvoke v.<java.util.LinkedHashSet: void <init>()>();
v.<org.apache.activemq.console.command.QueryCommand: java.util.Set queryViews> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(10);
v.<org.apache.activemq.console.command.QueryCommand: java.util.List opAndParams> = v;
return;
}
public java.lang.String getName()
{
org.apache.activemq.console.command.QueryCommand v;
v := @this: org.apache.activemq.console.command.QueryCommand;
return "query";
}
public java.lang.String getOneLineDescription()
{
org.apache.activemq.console.command.QueryCommand v;
v := @this: org.apache.activemq.console.command.QueryCommand;
return "Display selected broker component\'s attributes and statistics.";
}
protected void runTask(java.util.List) throws java.lang.Exception
{
java.util.ArrayList v;
java.util.Map v, v;
int v;
boolean v;
javax.management.MBeanServerConnection v, v;
org.apache.activemq.console.CommandContext v, v;
java.util.Collection v, v;
java.util.Set v, v, v, v, v, v;
java.util.List v, v, v, v, v, v, v;
org.apache.activemq.console.command.QueryCommand v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.util.List;
v = virtualinvoke v.<org.apache.activemq.console.command.QueryCommand: javax.management.MBeanServerConnection createJmxConnection()>();
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List queryAddObjects>;
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.Set queryViews>;
v = staticinvoke <org.apache.activemq.console.util.JmxMBeansUtil: java.util.Map queryMBeansAsMap(javax.management.MBeanServerConnection,java.util.List,java.util.Set)>(v, v, v);
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List querySubObjects>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.console.command.QueryCommand: javax.management.MBeanServerConnection createJmxConnection()>();
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List querySubObjects>;
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.Set queryViews>;
v = staticinvoke <org.apache.activemq.console.util.JmxMBeansUtil: java.util.Map queryMBeansAsMap(javax.management.MBeanServerConnection,java.util.List,java.util.Set)>(v, v, v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
interfaceinvoke v.<java.util.Set: boolean removeAll(java.util.Collection)>(v);
label:
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List opAndParams>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.Set queryViews>;
v = staticinvoke <org.apache.activemq.console.util.JmxMBeansUtil: java.util.List filterMBeansView(java.util.List,java.util.Set)>(v, v);
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printMBean(java.util.Collection)>(v);
goto label;
label:
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List opAndParams>;
v = specialinvoke v.<org.apache.activemq.console.command.QueryCommand: java.util.Collection doInvoke(java.util.Set,java.util.List)>(v, v);
virtualinvoke v.<org.apache.activemq.console.CommandContext: void print(java.util.Collection)>(v);
label:
return;
}
private java.util.Collection doInvoke(java.util.Set, java.util.List) throws java.lang.Exception
{
java.lang.Object[] v;
javax.management.MBeanServerConnection v;
java.util.Iterator v;
java.util.Set v;
java.lang.String[] v;
java.util.List v;
java.lang.Object v, v, v, v;
java.lang.String v;
java.util.LinkedList v;
org.apache.activemq.console.command.QueryCommand v;
boolean v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.util.Set;
v := @parameter: java.util.List;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
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 = virtualinvoke v.<org.apache.activemq.console.command.QueryCommand: javax.management.MBeanServerConnection createJmxConnection()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = specialinvoke v.<org.apache.activemq.console.command.QueryCommand: java.lang.Object[] params(java.util.List)>(v);
v = specialinvoke v.<org.apache.activemq.console.command.QueryCommand: java.lang.String[] stringSignature(java.util.List)>(v);
v = interfaceinvoke v.<javax.management.MBeanServerConnection: java.lang.Object invoke(javax.management.ObjectName,java.lang.String,java.lang.Object[],java.lang.String[])>(v, v, v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object,java.lang.Object,java.lang.Object)>(v, 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[])>("[\u].\u = \u0001");
virtualinvoke v.<java.util.LinkedList: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
private java.lang.Object[] params(java.util.List)
{
java.util.List v, v;
java.lang.Object[] v;
int v, v;
org.apache.activemq.console.command.QueryCommand v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.util.List;
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 1 goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
v = interfaceinvoke v.<java.util.List: java.util.List subList(int,int)>(1, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
return v;
label:
return null;
}
private java.lang.String[] stringSignature(java.util.List)
{
java.lang.String[] v;
java.util.List v;
int v, v, v;
java.lang.Class v;
java.lang.String v;
org.apache.activemq.console.command.QueryCommand v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.util.List;
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 1 goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v - 1;
v = newarray (java.lang.String)[v];
v = class "Ljava/lang/String;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
staticinvoke <java.util.Arrays: void fill(java.lang.Object[],java.lang.Object)>(v, v);
return v;
label:
return null;
}
protected void handleOption(java.lang.String, java.util.List) throws java.lang.Exception
{
java.util.Set v;
java.util.StringTokenizer v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Properties v, v;
org.apache.activemq.console.command.QueryCommand v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.console.CommandContext v, v, v, v, v, v;
java.util.List v, v, v, v, v, v, v, v;
int v, v, v, v;
java.lang.IllegalArgumentException v, v, v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("-Q");
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(2);
v = "";
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>("=");
if v < 0 goto label;
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
label:
v = <org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY>;
v = virtualinvoke v.<java.util.Properties: java.lang.String getProperty(java.lang.String)>(v);
if v != null goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalArgumentException;
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[])>("Unknown query object type: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
return;
label:
v = staticinvoke <org.apache.activemq.console.util.JmxMBeansUtil: java.lang.String createQueryString(java.lang.String,java.lang.String)>(v, v);
v = new java.util.StringTokenizer;
specialinvoke v.<java.util.StringTokenizer: void <init>(java.lang.String,java.lang.String)>(v, ",");
label:
v = virtualinvoke v.<java.util.StringTokenizer: boolean hasMoreTokens()>();
if v == 0 goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List queryAddObjects>;
v = virtualinvoke v.<java.util.StringTokenizer: java.lang.String nextToken()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List queryAddObjects>;
specialinvoke v.<org.apache.activemq.console.command.QueryCommand: void normaliseObjectName(java.util.List)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("-xQ");
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(3);
v = "";
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>("=");
if v < 0 goto label;
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
label:
v = <org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY>;
v = virtualinvoke v.<java.util.Properties: java.lang.String getProperty(java.lang.String)>(v);
if v != null goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalArgumentException;
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[])>("Unknown query object type: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
return;
label:
v = staticinvoke <org.apache.activemq.console.util.JmxMBeansUtil: java.lang.String createQueryString(java.lang.String,java.lang.String)>(v, v);
v = new java.util.StringTokenizer;
specialinvoke v.<java.util.StringTokenizer: void <init>(java.lang.String,java.lang.String)>(v, ",");
label:
v = virtualinvoke v.<java.util.StringTokenizer: boolean hasMoreTokens()>();
if v == 0 goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List querySubObjects>;
v = virtualinvoke v.<java.util.StringTokenizer: java.lang.String nextToken()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List querySubObjects>;
specialinvoke v.<org.apache.activemq.console.command.QueryCommand: void normaliseObjectName(java.util.List)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("--objname");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("-");
if v == 0 goto label;
label:
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Object name query not specified");
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
return;
label:
v = new java.util.StringTokenizer;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
specialinvoke v.<java.util.StringTokenizer: void <init>(java.lang.String,java.lang.String)>(v, ",");
label:
v = virtualinvoke v.<java.util.StringTokenizer: boolean hasMoreTokens()>();
if v == 0 goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List queryAddObjects>;
v = virtualinvoke v.<java.util.StringTokenizer: java.lang.String nextToken()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("--xobjname");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("-");
if v == 0 goto label;
label:
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Object name query not specified");
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
return;
label:
v = new java.util.StringTokenizer;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
specialinvoke v.<java.util.StringTokenizer: void <init>(java.lang.String,java.lang.String)>(v, ",");
label:
v = virtualinvoke v.<java.util.StringTokenizer: boolean hasMoreTokens()>();
if v == 0 goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List querySubObjects>;
v = virtualinvoke v.<java.util.StringTokenizer: java.lang.String nextToken()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("--view");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("-");
if v == 0 goto label;
label:
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Attributes to view not specified");
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
return;
label:
v = new java.util.StringTokenizer;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
specialinvoke v.<java.util.StringTokenizer: void <init>(java.lang.String,java.lang.String)>(v, ",");
label:
v = interfaceinvoke v.<java.util.Enumeration: boolean hasMoreElements()>();
if v == 0 goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.Set queryViews>;
v = interfaceinvoke v.<java.util.Enumeration: java.lang.Object nextElement()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("--invoke");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("-");
if v == 0 goto label;
label:
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("operation to invoke is not specified");
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
return;
label:
v = new java.util.StringTokenizer;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
specialinvoke v.<java.util.StringTokenizer: void <init>(java.lang.String,java.lang.String)>(v, ",");
label:
v = interfaceinvoke v.<java.util.Enumeration: boolean hasMoreElements()>();
if v == 0 goto label;
v = v.<org.apache.activemq.console.command.QueryCommand: java.util.List opAndParams>;
v = interfaceinvoke v.<java.util.Enumeration: java.lang.Object nextElement()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
specialinvoke v.<org.apache.activemq.console.command.AbstractJmxCommand: void handleOption(java.lang.String,java.util.List)>(v, v);
label:
return;
}
private void normaliseObjectName(java.util.List)
{
java.util.List v;
org.apache.activemq.console.command.QueryCommand v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.util.List;
specialinvoke v.<org.apache.activemq.console.command.QueryCommand: void ensurePresent(java.util.List,java.lang.String,java.lang.String)>(v, "type", "Broker");
specialinvoke v.<org.apache.activemq.console.command.QueryCommand: void ensurePresent(java.util.List,java.lang.String,java.lang.String)>(v, "brokerName", "*");
specialinvoke v.<org.apache.activemq.console.command.QueryCommand: void ensureUnique(java.util.List,java.lang.String,java.lang.String)>(v, "destinationType", "?????");
specialinvoke v.<org.apache.activemq.console.command.QueryCommand: void ensureUnique(java.util.List,java.lang.String,java.lang.String)>(v, "destinationName", "*");
return;
}
private void ensurePresent(java.util.List, java.lang.String, java.lang.String)
{
java.util.List v, v;
int v;
java.lang.String v, v, v;
org.apache.activemq.console.command.QueryCommand v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.activemq.console.command.QueryCommand: java.util.List findMatchingKeys(java.util.List,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto 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[])>("\u0001=\u0001");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
}
private void ensureUnique(java.util.List, java.lang.String, java.lang.String)
{
java.util.List v, v;
int v;
java.lang.String v, v, v;
org.apache.activemq.console.command.QueryCommand v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.activemq.console.command.QueryCommand: java.util.List findMatchingKeys(java.util.List,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 1 goto label;
interfaceinvoke v.<java.util.List: boolean removeAll(java.util.Collection)>(v);
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");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
}
private java.util.List findMatchingKeys(java.util.List, java.lang.String)
{
java.util.Iterator v;
java.lang.String[] v;
java.util.List v;
int v;
java.lang.Object v;
java.lang.String v, v;
java.util.LinkedList v;
org.apache.activemq.console.command.QueryCommand v;
boolean v, v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v = interfaceinvoke v.<java.util.List: 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 = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("=");
v = lengthof v;
if v != 2 goto label;
v = v[0];
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
protected void printHelp()
{
java.lang.String[] v;
org.apache.activemq.console.command.QueryCommand v;
org.apache.activemq.console.CommandContext v;
v := @this: org.apache.activemq.console.command.QueryCommand;
v = v.<org.apache.activemq.console.command.QueryCommand: org.apache.activemq.console.CommandContext context>;
v = v.<org.apache.activemq.console.command.QueryCommand: java.lang.String[] helpFile>;
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printHelp(java.lang.String[])>(v);
return;
}
static void <clinit>()
{
java.util.Properties v, v, v, v, v, v, v;
v = new java.util.Properties;
specialinvoke v.<java.util.Properties: void <init>()>();
<org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY> = v;
v = <org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY>;
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("Broker", "brokerName=%1");
v = <org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY>;
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("Connection", "connector=clientConnectors,connectionViewType=*,connectionName=%1,*");
v = <org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY>;
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("Connector", "connector=clientConnectors,connectorName=%1");
v = <org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY>;
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("NetworkConnector", "connector=networkConnectors,networkConnectorName=%1");
v = <org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY>;
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("Queue", "destinationType=Queue,destinationName=%1");
v = <org.apache.activemq.console.command.QueryCommand: java.util.Properties PREDEFINED_OBJNAME_QUERY>;
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>("Topic", "destinationType=Topic,destinationName=%1");
return;
}
}