| Methods Summary |
|---|
| public void | addCommandPrototype(org.jboss.console.twiddle.command.Command proto)
String name = proto.getName();
log.debug("Adding command '" + name + "'; proto: " + proto);
commandProtoList.add(proto);
commandProtoMap.put(name, proto);
|
| private void | connect()
if (server == null)
{
server = createMBeanServerConnection();
}
|
| public org.jboss.console.twiddle.command.Command | createCommand(java.lang.String name)
//
// jason: need to change this to accept unique substrings on command names
//
Command proto = (Command) commandProtoMap.get(name);
if (proto == null)
{
throw new NoSuchCommandException(name);
}
Command command = (Command) proto.clone();
command.setCommandContext(createCommandContext());
return command;
|
| private org.jboss.console.twiddle.command.CommandContext | createCommandContext()
return new CommandContext()
{
public boolean isQuiet()
{
return quiet;
}
public PrintWriter getWriter()
{
return out;
}
public PrintWriter getErrorWriter()
{
return err;
}
public MBeanServerConnection getServer()
{
try
{
connect();
}
catch (Exception e)
{
throw new org.jboss.util.NestedRuntimeException(e);
}
return server;
}
};
|
| private javax.management.MBeanServerConnection | createMBeanServerConnection()
InitialContext ctx;
if (serverURL == null)
{
ctx = new InitialContext();
}
else
{
Properties props = new Properties(System.getProperties());
props.put(Context.PROVIDER_URL, serverURL);
ctx = new InitialContext(props);
}
// if adapter is null, the use the default
if (adapterName == null)
{
adapterName = DEFAULT_JNDI_NAME;
}
Object obj = ctx.lookup(adapterName);
ctx.close();
if (!(obj instanceof RMIAdaptor))
{
throw new ClassCastException
("Object not of type: RMIAdaptorImpl, but: " +
(obj == null ? "not found" : obj.getClass().getName()));
}
return (MBeanServerConnection) obj;
|
| public void | displayCommandList()
if( commandProtoList.size() == 0 )
{
try
{
loadCommands();
}
catch(Exception e)
{
System.err.println("Failed to load commnads from: "+cmdProps);
e.printStackTrace();
}
}
Iterator iter = commandProtoList.iterator();
out.println(PROGRAM_NAME + " commands: ");
int maxNameLength = getMaxCommandNameLength();
log.debug("max command name length: " + maxNameLength);
while (iter.hasNext())
{
Command proto = (Command) iter.next();
String name = proto.getName();
String desc = proto.getDescription();
out.print(" ");
out.print(name);
// an even pad, so things line up correctly
out.print(Strings.pad(" ", maxNameLength - name.length()));
out.print(" ");
out.println(desc);
}
out.flush();
|
| private static void | displayHelp()
java.io.PrintStream out = System.out;
out.println("A JMX client to 'twiddle' with a remote JBoss server.");
out.println();
out.println("usage: " + PROGRAM_NAME + " [options] <command> [command_arguments]");
out.println();
out.println("options:");
out.println(" -h, --help Show this help message");
out.println(" --help-commands Show a list of commands");
out.println(" -H=<command> Show command specific help");
out.println(" -c=command.properties Specify the command.properties file to use");
out.println(" -D<name>[=<value>] Set a system property");
out.println(" -- Stop processing options");
out.println(" -s, --server=<url> The JNDI URL of the remote server");
out.println(" -a, --adapter=<name> The JNDI name of the RMI adapter to use");
out.println(" -u, --user=<name> Specify the username for authentication");
out.println(" -p, --password=<name> Specify the password for authentication");
out.println(" -q, --quiet Be somewhat more quiet");
out.flush();
|
| private int | getMaxCommandNameLength()
int max = 0;
Iterator iter = commandProtoList.iterator();
while (iter.hasNext())
{
Command command = (Command) iter.next();
String name = command.getName();
if (name.length() > max)
{
max = name.length();
}
}
return max;
|
| private static void | initProtocolHandlers()
// Include the default JBoss protocol handler package
String handlerPkgs = System.getProperty("java.protocol.handler.pkgs");
if (handlerPkgs != null)
{
handlerPkgs += "|org.jboss.net.protocol";
}
else
{
handlerPkgs = "org.jboss.net.protocol";
}
System.setProperty("java.protocol.handler.pkgs", handlerPkgs);
|
| private static void | loadCommands()
// load command protos from property definitions
if( cmdProps == null )
cmdProps = Twiddle.class.getResource(CMD_PROPERTIES);
if (cmdProps == null)
throw new IllegalStateException("Failed to find: " + CMD_PROPERTIES);
InputStream input = cmdProps.openStream();
log.debug("command proto type properties: " + cmdProps);
Properties props = new Properties();
props.load(input);
input.close();
Iterator iter = props.keySet().iterator();
while (iter.hasNext())
{
String name = (String) iter.next();
String typeName = props.getProperty(name);
Class type = Class.forName(typeName);
twiddle.addCommandPrototype((Command) type.newInstance());
}
|
| public static void | main(java.lang.String[] args)
Command command = null;
try
{
// initialize java.protocol.handler.pkgs
initProtocolHandlers();
// Prosess global options
processArguments(args);
loadCommands();
// Now execute the command
if (commandName == null)
{
// Display program help
displayHelp();
}
else
{
command = twiddle.createCommand(commandName);
if (commandHelp)
{
System.out.println("Help for command: '" + command.getName() + "'");
System.out.println();
command.displayHelp();
}
else
{
// Execute the command
command.execute(commandArgs);
}
}
System.exit(0);
}
catch (CommandException e)
{
log.error("Command failure", e);
System.err.println();
if (e instanceof NoSuchCommandException)
{
twiddle.displayCommandList();
}
else
{
if (command != null)
{
System.err.println("Help for command: '" + command.getName() + "'");
System.err.println();
command.displayHelp();
}
}
System.exit(1);
}
catch (Exception e)
{
log.error("Exec failed", e);
System.exit(1);
}
|
| private static void | processArguments(java.lang.String[] args)
for(int a = 0; a < args.length; a ++)
{
log.debug("args["+a+"]="+args[a]);
}
String sopts = "-:hH:u:p:c:D:s:a:q";
LongOpt[] lopts =
{
new LongOpt("help", LongOpt.NO_ARGUMENT, null, 'h"),
new LongOpt("help-commands", LongOpt.NO_ARGUMENT, null, 0x1000),
new LongOpt("server", LongOpt.REQUIRED_ARGUMENT, null, 's"),
new LongOpt("adapter", LongOpt.REQUIRED_ARGUMENT, null, 'a"),
new LongOpt("quiet", LongOpt.NO_ARGUMENT, null, 'q"),
new LongOpt("user", LongOpt.REQUIRED_ARGUMENT, null, 'u"),
new LongOpt("password", LongOpt.REQUIRED_ARGUMENT, null, 'p"),
};
Getopt getopt = new Getopt(PROGRAM_NAME, args, sopts, lopts);
int code;
PROCESS_ARGUMENTS:
while ((code = getopt.getopt()) != -1)
{
switch (code)
{
case ':":
case '?":
// for now both of these should exit with error status
System.exit(1);
break; // for completeness
// non-option arguments
case 1:
{
// create the command
commandName = getopt.getOptarg();
log.debug("Command name: " + commandName);
// pass the remaining arguments (if any) to the command for processing
int i = getopt.getOptind();
if (args.length > i)
{
commandArgs = new String[args.length - i];
System.arraycopy(args, i, commandArgs, 0, args.length - i);
}
else
{
commandArgs = new String[0];
}
// Log the command options
log.debug("Command arguments: " + Strings.join(commandArgs, ","));
// We are done, execute the command
break PROCESS_ARGUMENTS;
}
// show command line help
case 'h":
displayHelp();
System.exit(0);
break; // for completeness
// Show command help
case 'H":
commandName = getopt.getOptarg();
commandHelp = true;
break PROCESS_ARGUMENTS;
// help-commands
case 0x1000:
twiddle.displayCommandList();
System.exit(0);
break; // for completeness
case 'c":
// Try value as a URL
String props = getopt.getOptarg();
try
{
cmdProps = new URL(props);
}
catch (MalformedURLException e)
{
log.debug("Failed to use cmd props as url", e);
File path = new File(props);
if( path.exists() == false )
{
String msg = "Failed to locate command props: " + props
+ " as URL or file";
throw new IllegalArgumentException(msg);
}
cmdProps = path.toURL();
}
break;
// set a system property
case 'D":
{
String arg = getopt.getOptarg();
String name, value;
int i = arg.indexOf("=");
if (i == -1)
{
name = arg;
value = "true";
}
else
{
name = arg.substring(0, i);
value = arg.substring(i + 1, arg.length());
}
System.setProperty(name, value);
break;
}
// Set the JNDI server URL
case 's":
twiddle.setServerURL(getopt.getOptarg());
break;
// Set the adapter JNDI name
case 'a":
twiddle.setAdapterName(getopt.getOptarg());
break;
case 'u":
String username = getopt.getOptarg();
SecurityAssociation.setPrincipal(new SimplePrincipal(username));
break;
case 'p":
String password = getopt.getOptarg();
SecurityAssociation.setCredential(password);
break;
// Enable quiet operations
case 'q":
twiddle.setQuiet(true);
break;
}
}
|
| public void | setAdapterName(java.lang.String name)
this.adapterName = name;
|
| public void | setQuiet(boolean flag)
this.quiet = flag;
|
| public void | setServerURL(java.lang.String url)
this.serverURL = url;
|
