public abstract class org.apache.activemq.console.command.AbstractAmqCommand extends org.apache.activemq.console.command.AbstractCommand
{
private java.net.URI brokerUrl;
private javax.jms.ConnectionFactory factory;
private java.lang.String factoryClassString;
private java.lang.String username;
private java.lang.String password;
private org.apache.activemq.console.command.PasswordFactory passwordFactory;
private final java.util.List connections;
private java.lang.String passwordFactoryClassString;
public void <init>()
{
org.apache.activemq.console.command.AbstractAmqCommand v;
java.util.ArrayList v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
specialinvoke v.<org.apache.activemq.console.command.AbstractCommand: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.util.List connections> = v;
return;
}
protected javax.jms.Connection createConnection() throws javax.jms.JMSException
{
javax.jms.Connection v;
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.String v, v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getUsername()>();
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getPassword()>();
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.Connection createConnection(java.lang.String,java.lang.String)>(v, v);
return v;
}
protected javax.jms.Connection createConnection(java.lang.String, java.lang.String) throws javax.jms.JMSException
{
java.lang.IllegalStateException v;
javax.jms.Connection v;
org.apache.activemq.console.CommandContext v;
org.apache.activemq.console.command.AbstractAmqCommand v;
java.util.List v;
java.lang.String v, v;
java.net.URI v;
javax.jms.ConnectionFactory v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI getBrokerUrl()>();
if v != null goto label;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("You must specify a broker URL to connect to using the --amqurl option.");
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
return null;
label:
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory getConnectionFactory()>();
if null != v goto label;
if null != v goto label;
v = interfaceinvoke v.<javax.jms.ConnectionFactory: javax.jms.Connection createConnection()>();
goto label;
label:
v = interfaceinvoke v.<javax.jms.ConnectionFactory: javax.jms.Connection createConnection(java.lang.String,java.lang.String)>(v, v);
label:
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.util.List connections>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
interfaceinvoke v.<javax.jms.Connection: void start()>();
return v;
}
protected void closeAllConnections()
{
java.util.List v, v;
java.util.Iterator v;
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.Object v;
java.lang.Exception v;
boolean v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.util.List connections>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
label:
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<javax.jms.Connection: void close()>();
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.util.List connections>;
interfaceinvoke v.<java.util.List: void clear()>();
return;
catch java.lang.Exception from label to label with label;
}
protected void handleOption(java.lang.String, java.util.List) throws java.lang.Exception
{
java.net.URISyntaxException v;
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.String v;
java.net.URI v, v;
boolean v, v, v, v, v, v, v;
org.apache.activemq.console.CommandContext v, v, v;
java.lang.IllegalArgumentException v, v;
java.util.List v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("--amqurl");
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.AbstractAmqCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Broker URL not specified.");
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
interfaceinvoke v.<java.util.List: void clear()>();
return;
label:
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI getBrokerUrl()>();
if v == null goto label;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.CommandContext context>;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Multiple broker URL cannot be specified.");
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
interfaceinvoke v.<java.util.List: void clear()>();
return;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
label:
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: void setBrokerUrl(java.net.URI)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.CommandContext context>;
virtualinvoke v.<org.apache.activemq.console.CommandContext: void printException(java.lang.Exception)>(v);
interfaceinvoke v.<java.util.List: void clear()>();
return;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("--factory");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String factoryClassString> = v;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("--passwordFactory");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String passwordFactoryClassString> = v;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("--password");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String password> = v;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("--user");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String username> = v;
goto label;
label:
specialinvoke v.<org.apache.activemq.console.command.AbstractCommand: void handleOption(java.lang.String,java.util.List)>(v, v);
label:
return;
catch java.net.URISyntaxException from label to label with label;
}
protected void setBrokerUrl(java.net.URI)
{
org.apache.activemq.console.command.AbstractAmqCommand v;
java.net.URI v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v := @parameter: java.net.URI;
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI brokerUrl> = v;
return;
}
protected void setBrokerUrl(java.lang.String) throws java.net.URISyntaxException
{
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.String v;
java.net.URI v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v := @parameter: java.lang.String;
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI brokerUrl> = v;
return;
}
protected java.net.URI getBrokerUrl()
{
org.apache.activemq.console.command.AbstractAmqCommand v;
java.net.URI v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI brokerUrl>;
return v;
}
public javax.jms.ConnectionFactory getConnectionFactory()
{
java.lang.Object[] v, v;
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.reflect.Constructor v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
java.net.URI v, v, v, v;
java.lang.Class[] v, v;
java.lang.RuntimeException v;
java.lang.Exception v;
org.apache.activemq.ActiveMQConnectionFactory v, v;
java.lang.Class v;
java.lang.Object v, v;
javax.jms.ConnectionFactory v, v, v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory factory>;
if v != null goto label;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String factoryClassString>;
if v == null goto label;
label:
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String factoryClassString>;
v = staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getUsername()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getPassword()>();
if v == null goto label;
label:
v = newarray (java.lang.Class)[3];
v[0] = class "Ljava/lang/String;";
v[1] = class "Ljava/lang/String;";
v[2] = class "Ljava/net/URI;";
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Constructor getConstructor(java.lang.Class[])>(v);
v = newarray (java.lang.Object)[3];
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getUsername()>();
v[0] = v;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getPassword()>();
v[1] = v;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI getBrokerUrl()>();
v[2] = v;
v = virtualinvoke v.<java.lang.reflect.Constructor: java.lang.Object newInstance(java.lang.Object[])>(v);
v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory factory> = v;
goto label;
label:
v = newarray (java.lang.Class)[1];
v[0] = class "Ljava/net/URI;";
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Constructor getConstructor(java.lang.Class[])>(v);
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI getBrokerUrl()>();
v[0] = v;
v = virtualinvoke v.<java.lang.reflect.Constructor: java.lang.Object newInstance(java.lang.Object[])>(v);
v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory factory> = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory factory>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getUsername()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getPassword()>();
if v == null goto label;
label:
v = new org.apache.activemq.ActiveMQConnectionFactory;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getUsername()>();
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String getPassword()>();
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI getBrokerUrl()>();
specialinvoke v.<org.apache.activemq.ActiveMQConnectionFactory: void <init>(java.lang.String,java.lang.String,java.net.URI)>(v, v, v);
v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory factory> = v;
goto label;
label:
v = new org.apache.activemq.ActiveMQConnectionFactory;
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: java.net.URI getBrokerUrl()>();
specialinvoke v.<org.apache.activemq.ActiveMQConnectionFactory: void <init>(java.net.URI)>(v);
v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory factory> = v;
label:
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory factory>;
return v;
catch java.lang.Exception from label to label with label;
}
public java.lang.String getUsername()
{
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.String v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String username>;
return v;
}
public void setFactory(javax.jms.ConnectionFactory)
{
org.apache.activemq.console.command.AbstractAmqCommand v;
javax.jms.ConnectionFactory v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v := @parameter: javax.jms.ConnectionFactory;
v.<org.apache.activemq.console.command.AbstractAmqCommand: javax.jms.ConnectionFactory factory> = v;
return;
}
public void setUsername(java.lang.String)
{
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.String v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v := @parameter: java.lang.String;
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String username> = v;
return;
}
public java.lang.String getPassword()
{
org.apache.activemq.console.command.PasswordFactory v;
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.String v, v, v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String password>;
if null != v goto label;
return null;
label:
v = virtualinvoke v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.command.PasswordFactory getPasswordFactory()>();
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String password>;
v = interfaceinvoke v.<org.apache.activemq.console.command.PasswordFactory: java.lang.String getPassword(java.lang.String)>(v);
return v;
}
public void setPassword(java.lang.String)
{
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.String v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v := @parameter: java.lang.String;
v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String password> = v;
return;
}
public org.apache.activemq.console.command.PasswordFactory getPasswordFactory()
{
org.apache.activemq.console.command.AbstractAmqCommand v;
java.lang.RuntimeException v;
java.lang.Exception v;
org.apache.activemq.console.command.PasswordFactory v, v, v, v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v, v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.command.PasswordFactory passwordFactory>;
if v != null goto label;
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String passwordFactoryClassString>;
if v == null goto label;
label:
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: java.lang.String passwordFactoryClassString>;
v = staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Class: java.lang.Object newInstance()>();
v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.command.PasswordFactory passwordFactory> = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.command.PasswordFactory passwordFactory>;
if v != null goto label;
v = <org.apache.activemq.console.command.DefaultPasswordFactory: org.apache.activemq.console.command.PasswordFactory factory>;
v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.command.PasswordFactory passwordFactory> = v;
label:
v = v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.command.PasswordFactory passwordFactory>;
return v;
catch java.lang.Exception from label to label with label;
}
public void setPasswordFactory(org.apache.activemq.console.command.PasswordFactory)
{
org.apache.activemq.console.command.AbstractAmqCommand v;
org.apache.activemq.console.command.PasswordFactory v;
v := @this: org.apache.activemq.console.command.AbstractAmqCommand;
v := @parameter: org.apache.activemq.console.command.PasswordFactory;
v.<org.apache.activemq.console.command.AbstractAmqCommand: org.apache.activemq.console.command.PasswordFactory passwordFactory> = v;
return;
}
}