Menu
▾
▴
[Maven-plugins-cvs] cvs commit: maven-plugins/was5config/src/java/org/apache/maven/was5/namespace NameSpaceBindingHandler.java
|
From: dion g. <dio...@us...> - 2005-11-02 23:25:13
|
diongillard 05/11/02 15:25:07
Added: was5config/src/java/org/apache/maven/was5
MissingArgumentException.java
ScriptFileBuilder.java ScriptFileHandler.java
StringUtil.java
was5config/src/java/org/apache/maven/was5/jaas
JAASAuthDataHandler.java
was5config/src/java/org/apache/maven/was5/jdbc
JDBCDatasourceHandler.java JDBCProviderHandler.java
was5config/src/java/org/apache/maven/was5/listenerport
ListenerportHandler.java
was5config/src/java/org/apache/maven/was5/mq QCFHandler.java
QueueHandler.java TCFHandler.java TopicHandler.java
was5config/src/java/org/apache/maven/was5/namespace
NameSpaceBindingHandler.java
Log:
Added from previous ocation
Revision Changes Path
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/MissingArgumentException.java
Index: MissingArgumentException.java
===================================================================
package org.apache.maven.was5;
/**
*
* @author Morten Kristiansen
*/
public class MissingArgumentException extends Exception {
public MissingArgumentException(String arg) {
super("Required argument \"" + arg + "\" missing");
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/ScriptFileBuilder.java
Index: ScriptFileBuilder.java
===================================================================
package org.apache.maven.was5;
import java.io.File;
import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;
/**
*
* @author Morten Kristiansen
*/
public final class ScriptFileBuilder {
public String build(String myScriptArgsHandlerClass, String myXml) {
try {
ScriptFileHandler handler = (ScriptFileHandler) Class.forName(myScriptArgsHandlerClass).newInstance();
SAXParserFactory factory = SAXParserFactory.newInstance();
SAXParser saxParser = factory.newSAXParser();
saxParser.parse(new File(myXml), handler);
return handler.generateFile();
} catch (Throwable t) {
return t.getMessage();
}
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/ScriptFileHandler.java
Index: ScriptFileHandler.java
===================================================================
package org.apache.maven.was5;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.xml.sax.helpers.DefaultHandler;
/**
*
* @author Morten Kristiansen
*/
public abstract class ScriptFileHandler extends DefaultHandler {
private List myWsAdminScriptArgs = new ArrayList();
private Map myGlobals = new HashMap();
protected void addArgs(Object args) {
myWsAdminScriptArgs.add(args);
}
protected void addGlobal(String key, String value) {
myGlobals.put(key, value);
}
protected List getArgs() {
return myWsAdminScriptArgs;
}
protected String getGlobal(String key) {
return myGlobals.containsKey(key) ? (String) myGlobals.get(key) : null;
}
protected void addDefaultHeader(PrintWriter printwriter) {
printwriter.println("global AdminConfig");
printwriter.println("global AdminControl");
printwriter.println("set cell [$AdminControl getCell]");
}
protected void required(String arg, String desc) throws MissingArgumentException {
if(arg == null || arg.trim().equals("")) {
throw new MissingArgumentException(desc);
}
}
protected abstract String generateFile();
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/StringUtil.java
Index: StringUtil.java
===================================================================
package org.apache.maven.was5;
/**
*
* @author Morten Kristiansen
*/
public final class StringUtil {
public static final String wrap(String s) {
return "\"" + s + "\"";
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/jaas/JAASAuthDataHandler.java
Index: JAASAuthDataHandler.java
===================================================================
package org.apache.maven.was5.jaas;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.util.Iterator;
import org.apache.maven.was5.ScriptFileHandler;
import org.apache.maven.was5.StringUtil;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
/**
*
* @author Morten Kristiansen
*/
public class JAASAuthDataHandler extends ScriptFileHandler {
class Args {
String alias = "";
String description = "";
String password = "";
String userId = "";
}
private Args myCurrent = null;
/**
* @param namespaceURI -
* @param sName -
* @param qName -
* @param attrs -
*
* @throws SAXException -
*/
public void startElement(String namespaceURI, String sName, String qName, Attributes attrs) throws SAXException {
String name = attrs.getValue("name");
if ("authdata".equals(qName)) {
myCurrent = new Args();
addArgs(myCurrent);
} else if ("alias".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.alias = name;
} else if ("userId".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.userId = name;
} else if ("password".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.password = name;
} else if ("description".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.description = name;
}
}
protected String generateFile() {
try {
File file = File.createTempFile("wsant", "jacl");
PrintWriter printwriter = new PrintWriter(new FileWriter(file));
addDefaultHeader(printwriter);
printwriter.println("set security [$AdminConfig getid /Cell:$cell/Security:/]");
for (Iterator iter = getArgs().iterator(); iter.hasNext();) {
Args args = (Args) iter.next();
required(args.alias, "alias");
required(args.userId, "userId");
required(args.password, "password");
printwriter.println("puts \"Creating JAASAuthData " + args.alias + "\"");
String attrs = "{alias " + StringUtil.wrap(args.alias) + "} {userId " + StringUtil.wrap(args.userId) + "} {password " + StringUtil.wrap(args.password) + "}";
if(!args.description.equals("")) {
attrs = attrs + " {description " + StringUtil.wrap(args.description) + "}";
}
printwriter.println("set attrs [list " + attrs + "]");
printwriter.println("$AdminConfig create JAASAuthData $security $attrs");
printwriter.println("$AdminConfig save");
}
printwriter.println("puts \"Created " + getArgs().size() + "\"");
printwriter.flush();
printwriter.close();
return file.getAbsolutePath();
} catch (Throwable t) {
return t.getMessage();
}
}
public void endElement(String uri, String localName, String qName) throws SAXException {
if ("authdata".equals(qName)) {
myCurrent = null;
}
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/jdbc/JDBCDatasourceHandler.java
Index: JDBCDatasourceHandler.java
===================================================================
package org.apache.maven.was5.jdbc;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.apache.maven.was5.ScriptFileHandler;
import org.apache.maven.was5.StringUtil;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
/**
*
* @author Morten Kristiansen
*/
public class JDBCDatasourceHandler extends ScriptFileHandler {
class Args {
String providerName = "";
String node = "";
String server = "";
String name = "";
String jndiName = "";
String description = "";
String datasourceHelperClassname = "";
String authDataAlias = "";
String mappingConfigAlias = "DefaultPrincipalMapping";
String authMechanismPreference = "";
String category = "";
String statementCacheSize = "10";
List properties = new ArrayList();
}
class Property {
String name = "";
String type = "";
String value = "";
public boolean equals(Object obj) {
return (obj instanceof Property) && ((Property) obj).name.equals(this.name);
}
}
private Map myGlobalProperties = new HashMap();
private Args myCurrent = null;
/**
* @param namespaceURI -
* @param sName -
* @param qName -
* @param attrs -
*
* @throws SAXException -
*/
public void startElement(String namespaceURI, String sName, String qName, Attributes attrs) throws SAXException {
String name = attrs.getValue("name");
if ("datasource".equals(qName)) {
myCurrent = new Args();
myCurrent.providerName = getGlobal("providerName") != null ? getGlobal("providerName") : myCurrent.providerName;
myCurrent.node = getGlobal("node") != null ? getGlobal("node") : myCurrent.node;
myCurrent.server = getGlobal("server") != null ? getGlobal("server") : myCurrent.server;
myCurrent.datasourceHelperClassname = getGlobal("datasourceHelperClassname") != null ? getGlobal("datasourceHelperClassname") : myCurrent.datasourceHelperClassname;
myCurrent.authDataAlias = getGlobal("authDataAlias") != null ? getGlobal("authDataAlias") : myCurrent.authDataAlias;
myCurrent.mappingConfigAlias = getGlobal("mappingConfigAlias") != null ? getGlobal("mappingConfigAlias") : myCurrent.mappingConfigAlias;
myCurrent.authMechanismPreference = getGlobal("authMechanismPreference") != null ? getGlobal("authMechanismPreference") : myCurrent.authMechanismPreference;
myCurrent.category = getGlobal("category") != null ? getGlobal("category") : myCurrent.category;
myCurrent.statementCacheSize = getGlobal("statementCacheSize") != null ? getGlobal("statementCacheSize") : myCurrent.statementCacheSize;
addGlobalProperties(myCurrent);
addArgs(myCurrent);
} else if ("property".equals(qName)) {
String type = attrs.getValue("type");
String value = attrs.getValue("value");
Property prop = new Property();
prop.name = name;
prop.type = type;
prop.value = value;
if (myCurrent == null) {
addGlobalProperty(name, prop);
} else {
int index = myCurrent.properties.indexOf(prop);
if (index > -1) {
myCurrent.properties.remove(index);
}
myCurrent.properties.add(prop);
}
} else if ("providerName".equals(qName)) {
if (myCurrent == null) {
addGlobal("providerName", name);
} else {
myCurrent.providerName = name;
}
} else if ("node".equals(qName)) {
if (myCurrent == null) {
addGlobal("node", name);
} else {
myCurrent.node = name;
}
} else if ("server".equals(qName)) {
if (myCurrent == null) {
addGlobal("server", name);
} else {
myCurrent.server = name;
}
} else if ("datasourceHelperClassname".equals(qName)) {
if (myCurrent == null) {
addGlobal("datasourceHelperClassname", name);
} else {
myCurrent.datasourceHelperClassname = name;
}
} else if ("authDataAlias".equals(qName)) {
if (myCurrent == null) {
addGlobal("authDataAlias", name);
} else {
myCurrent.authDataAlias = name;
}
} else if ("mappingConfigAlias".equals(qName)) {
if (myCurrent == null) {
addGlobal("mappingConfigAlias", name);
} else {
myCurrent.mappingConfigAlias = name;
}
} else if ("authMechanismPreference".equals(qName)) {
if (myCurrent == null) {
addGlobal("authMechanismPreference", name);
} else {
myCurrent.authMechanismPreference = name;
}
} else if ("category".equals(qName)) {
if (myCurrent == null) {
addGlobal("category", name);
} else {
myCurrent.category = name;
}
} else if ("statementCacheSize".equals(qName)) {
if (myCurrent == null) {
addGlobal("statementCacheSize", name);
} else {
myCurrent.statementCacheSize = name;
}
} else if ("name".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.name = name;
} else if ("jndiName".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.jndiName = name;
} else if ("description".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.description = name;
}
}
private void addGlobalProperty(String key, Property value) {
myGlobalProperties.put(key, value);
}
private void addGlobalProperties(Args ds) {
for (Iterator iter = myGlobalProperties.values().iterator(); iter.hasNext();) {
Property prop = (Property) iter.next();
ds.properties.add(prop);
}
}
protected String generateFile() {
try {
File file = File.createTempFile("wsant", "jacl");
PrintWriter printwriter = new PrintWriter(new FileWriter(file));
addDefaultHeader(printwriter);
for (Iterator iter = getArgs().iterator(); iter.hasNext();) {
Args args = (Args) iter.next();
required(args.providerName, "providerName");
required(args.name, "name");
String path = "/Cell:$cell";
if (args.node != null && !args.node.trim().equals("")) {
path = path + "/Node:" + args.node;
}
if (args.server != null && !args.server.trim().equals("")) {
path = path + "/Server:" + args.server;
}
path = path + "/JDBCProvider:" + args.providerName + "/";
printwriter.println("if { [llength [$AdminConfig getid \"" + path + "\"]] == 0 } then {");
printwriter.println(" puts \"ProviderName " + args.providerName + " not found on " + path + "\"");
printwriter.println(" return");
printwriter.println("}");
printwriter.println("set prov [$AdminConfig getid \"" + path + "\"]");
printwriter.println("puts \"Creating JDBC Datasource " + args.name + "\"");
String attrs = "{name " + StringUtil.wrap(args.name) + "}";
if(!args.jndiName.equals("")) {
attrs = attrs + " {jndiName " + StringUtil.wrap(args.jndiName) + "}";
}
if(!args.description.equals("")) {
attrs = attrs + " {description " + StringUtil.wrap(args.description) + "}";
}
if(!args.datasourceHelperClassname.equals("")) {
attrs = attrs + " {datasourceHelperClassname " + StringUtil.wrap(args.datasourceHelperClassname) + "}";
}
if(!args.category.equals("")) {
attrs = attrs + " {category " + StringUtil.wrap(args.category) + "}";
}
if(!args.statementCacheSize.equals("")) {
attrs = attrs + " {statementCacheSize " + StringUtil.wrap(args.statementCacheSize) + "}";
}
if(!args.authMechanismPreference.equals("")) {
attrs = attrs + " {authMechanismPreference " + StringUtil.wrap(args.authMechanismPreference) + "}";
}
printwriter.println("set attrs [list " + attrs + "]");
printwriter.println("set ds [$AdminConfig create DataSource $prov $attrs]");
if (args.properties.size() > 0) {
printwriter.println("set customProps [$AdminConfig create J2EEResourcePropertySet $ds {}]");
int index = 0;
for (Iterator iterator = args.properties.iterator(); iterator.hasNext();) {
Property prop = (Property) iterator.next();
printwriter.println("set props_attr" + index
+ " [subst {{name " + prop.name + "} {type " + prop.type + "} {value " + StringUtil.wrap(prop.value) + "}}]");
printwriter.println("$AdminConfig create J2EEResourceProperty $customProps $props_attr" + index);
index++;
}
}
String mappings = "";
if (!args.authDataAlias.equals("")) {
mappings = "{authDataAlias " + StringUtil.wrap(args.authDataAlias) + "}";
}
if (!args.mappingConfigAlias.equals("")) {
mappings = mappings + " {mappingConfigAlias " + StringUtil.wrap(args.mappingConfigAlias) + "}";
}
if (!mappings.equals("")) {
printwriter.println("set mappedAlias [$AdminConfig create MappingModule $ds [subst {" + mappings + "}] mapping]");
}
printwriter.println("$AdminConfig save");
}
printwriter.println("puts \"Created " + getArgs().size() + "\"");
printwriter.flush();
printwriter.close();
return file.getAbsolutePath();
} catch (Throwable t) {
return t.getMessage();
}
}
public void endElement(String uri, String localName, String qName) throws SAXException {
if ("datasource".equals(qName)) {
myCurrent = null;
}
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/jdbc/JDBCProviderHandler.java
Index: JDBCProviderHandler.java
===================================================================
package org.apache.maven.was5.jdbc;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.util.Iterator;
import org.apache.maven.was5.ScriptFileHandler;
import org.apache.maven.was5.StringUtil;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
/**
*
* @author Morten Kristiansen
*/
public class JDBCProviderHandler extends ScriptFileHandler {
class Args {
String node = "";
String server = "";
String name = "";
String description = "";
String classpath = "";
String nativepath = "";
String implementationClassName = "";
}
private Args myCurrent = null;
/**
* @param namespaceURI -
* @param sName -
* @param qName -
* @param attrs -
*
* @throws SAXException -
*/
public void startElement(String namespaceURI, String sName, String qName, Attributes attrs) throws SAXException {
String name = attrs.getValue("name");
if ("provider".equals(qName)) {
myCurrent = new Args();
myCurrent.node = getGlobal("node") != null ? getGlobal("node") : myCurrent.node;
myCurrent.server = getGlobal("server") != null ? getGlobal("server") : myCurrent.server;
addArgs(myCurrent);
} else if ("node".equals(qName)) {
if (myCurrent == null) {
addGlobal("node", name);
} else {
myCurrent.node = name;
}
} else if ("server".equals(qName)) {
if (myCurrent == null) {
addGlobal("server", name);
} else {
myCurrent.server = name;
}
} else if ("name".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.name = name;
} else if ("description".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.description = name;
} else if ("classpath".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.classpath = name;
} else if ("implementationClassName".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.implementationClassName = name;
} else if ("nativepath".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.nativepath = name;
}
}
protected String generateFile() {
try {
File file = File.createTempFile("wsant", "jacl");
PrintWriter printwriter = new PrintWriter(new FileWriter(file));
addDefaultHeader(printwriter);
for (Iterator iter = getArgs().iterator(); iter.hasNext();) {
Args args = (Args) iter.next();
required(args.name, "name");
required(args.implementationClassName, "implementationClassName");
String path = "/Cell:$cell";
if (args.node != null && !args.node.trim().equals("")) {
path = path + "/Node:" + args.node;
}
if (args.server != null && !args.server.trim().equals("")) {
path = path + "/Server:" + args.server;
}
printwriter.println("set path [$AdminConfig getid " + path + "/]");
printwriter.println("puts \"Creating JDBC Provider " + args.name + "\"");
String attrs = "{name " + StringUtil.wrap(args.name) + "} {implementationClassName " + StringUtil.wrap(args.implementationClassName) + "}";
if(!args.description.equals("")) {
attrs = attrs + " {description " + StringUtil.wrap(args.description) + "}";
}
if(!args.classpath.equals("")) {
attrs = attrs + " {classpath " + StringUtil.wrap(args.classpath) + "}";
}
if(!args.nativepath.equals("")) {
attrs = attrs + " {nativepath " + StringUtil.wrap(args.nativepath) + "}";
}
printwriter.println("set attrs [list " + attrs + "]");
printwriter.println("$AdminConfig create JDBCProvider $path $attrs");
printwriter.println("$AdminConfig save");
}
printwriter.println("puts \"Created " + getArgs().size() + "\"");
printwriter.flush();
printwriter.close();
return file.getAbsolutePath();
} catch (Throwable t) {
return t.getMessage();
}
}
public void endElement(String uri, String localName, String qName) throws SAXException {
if ("provider".equals(qName)) {
myCurrent = null;
}
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/listenerport/ListenerportHandler.java
Index: ListenerportHandler.java
===================================================================
package org.apache.maven.was5.listenerport;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.util.Iterator;
import org.apache.maven.was5.ScriptFileHandler;
import org.apache.maven.was5.StringUtil;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
/**
*
* @author Morten Kristiansen
*/
public class ListenerportHandler extends ScriptFileHandler {
class Args {
String node = "";
String server = "";
String name = "";
String description = "";
String connectionFactoryJNDIName = "";
String destinationJNDIName = "";
String maxSessions = "1";
String maxRetries = "0";
String maxMessages = "1";
String initialState = "START";
}
private Args myCurrent = null;
/**
* @param namespaceURI -
* @param sName -
* @param qName -
* @param attrs -
*
* @throws SAXException -
*/
public void startElement(String namespaceURI, String sName, String qName, Attributes attrs) throws SAXException {
String value = attrs.getValue("name");
if ("listenerport".equals(qName)) {
myCurrent = new Args();
myCurrent.node = getGlobal("node") != null ? getGlobal("node") : myCurrent.node;
myCurrent.server = getGlobal("server") != null ? getGlobal("server") : myCurrent.server;
myCurrent.connectionFactoryJNDIName = getGlobal("connectionFactoryJNDIName") != null ? getGlobal("connectionFactoryJNDIName") : myCurrent.connectionFactoryJNDIName;
myCurrent.destinationJNDIName = getGlobal("destinationJNDIName") != null ? getGlobal("destinationJNDIName") : myCurrent.destinationJNDIName;
myCurrent.maxSessions = getGlobal("maxSessions") != null ? getGlobal("maxSessions") : myCurrent.maxSessions;
myCurrent.maxRetries = getGlobal("maxRetries") != null ? getGlobal("maxRetries") : myCurrent.maxRetries;
myCurrent.maxMessages = getGlobal("maxMessages") != null ? getGlobal("maxMessages") : myCurrent.maxMessages;
myCurrent.initialState = getGlobal("initialState") != null ? getGlobal("initialState") : myCurrent.initialState;
addArgs(myCurrent);
} else if ("node".equals(qName)) {
if (myCurrent == null) {
addGlobal("node", value);
} else {
myCurrent.node = value;
}
} else if ("server".equals(qName)) {
if (myCurrent == null) {
addGlobal("server", value);
} else {
myCurrent.server = value;
}
} else if ("connectionFactoryJNDIName".equals(qName)) {
if (myCurrent == null) {
addGlobal("connectionFactoryJNDIName", value);
} else {
myCurrent.connectionFactoryJNDIName = value;
}
} else if ("destinationJNDIName".equals(qName)) {
if (myCurrent == null) {
addGlobal("destinationJNDIName", value);
} else {
myCurrent.destinationJNDIName = value;
}
} else if ("maxSessions".equals(qName)) {
if (myCurrent == null) {
addGlobal("maxSessions", value);
} else {
myCurrent.maxSessions = value;
}
} else if ("maxRetries".equals(qName)) {
if (myCurrent == null) {
addGlobal("maxRetries", value);
} else {
myCurrent.maxRetries = value;
}
} else if ("maxMessages".equals(qName)) {
if (myCurrent == null) {
addGlobal("maxMessages", value);
} else {
myCurrent.maxMessages = value;
}
} else if ("initialState".equals(qName)) {
if (myCurrent == null) {
addGlobal("initialState", value);
} else {
myCurrent.initialState = value;
}
} else if ("name".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.name = value;
} else if ("description".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.description = value;
}
}
protected String generateFile() {
try {
File file = File.createTempFile("wsant", "jacl");
PrintWriter printwriter = new PrintWriter(new FileWriter(file));
addDefaultHeader(printwriter);
for (Iterator iter = getArgs().iterator(); iter.hasNext();) {
Args args = (Args) iter.next();
required(args.node, "node");
required(args.server, "server");
required(args.name, "name");
required(args.initialState, "initialState");
required(args.connectionFactoryJNDIName, "connectionFactoryJNDIName");
required(args.destinationJNDIName, "destinationJNDIName");
printwriter.println("set theServer [$AdminConfig getid /Cell:$cell/Node:" + args.node + "/Server:" + args.server + "/]");
printwriter.println("if {[llength $theServer] ==0 } {");
printwriter.println(" puts \"Did not find server " + args.server + " on node " + args.node + " and cell $cell\"");
printwriter.println(" return");
printwriter.println("}");
printwriter.println("set mls [$AdminConfig list MessageListenerService $theServer]");
printwriter.println("puts \"Creating Listenerport " + args.name + "\"");
printwriter.println("set attr1 [list name " + StringUtil.wrap(args.name) + "]");
printwriter.println("set attr2 [list description " + StringUtil.wrap(args.description) + "]");
printwriter.println("set attr3 [list connectionFactoryJNDIName " + StringUtil.wrap(args.connectionFactoryJNDIName) + "]");
printwriter.println("set attr4 [list destinationJNDIName " + StringUtil.wrap(args.destinationJNDIName) + "]");
printwriter.println("set attr5 [list maxSessions " + StringUtil.wrap(args.maxSessions) + "]");
printwriter.println("set attr6 [list maxRetries " + StringUtil.wrap(args.maxRetries) + "]");
printwriter.println("set attr7 [list maxMessages " + StringUtil.wrap(args.maxMessages) + "]");
printwriter.println("set attr8 [list initialState " + StringUtil.wrap(args.initialState) + "]");
printwriter.println("set attr9 [list $attr8]");
printwriter.println("set attr10 [list stateManagement $attr9]");
printwriter.println("set attr [list $attr1 $attr2 $attr3 $attr4 $attr5 $attr6 $attr7 $attr10]");
printwriter.println("set newLP [$AdminConfig create ListenerPort $mls $attr]");
printwriter.println("$AdminConfig save");
}
printwriter.println("puts \"Created " + getArgs().size() + "\"");
printwriter.flush();
printwriter.close();
return file.getAbsolutePath();
} catch (Throwable t) {
return t.getMessage();
}
}
public void endElement(String uri, String localName, String qName) throws SAXException {
if ("listenerport".equals(qName)) {
myCurrent = null;
}
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/mq/QCFHandler.java
Index: QCFHandler.java
===================================================================
package org.apache.maven.was5.mq;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.util.Iterator;
import org.apache.maven.was5.ScriptFileHandler;
import org.apache.maven.was5.StringUtil;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
/**
*
* @author Morten Kristiansen
*/
public class QCFHandler extends ScriptFileHandler {
class Args {
String node = "";
String server = "";
String name = "";
String jndiName = "";
String description = "";
String CCSID = "";
String XAEnabled = "true";
String authDataAlias = "";
String authMechanismPreference = "";
String category = "";
String channel = "";
String clientID = "";
String host = "";
String mappingConfigAlias = "DefaultPrincipalMapping";
String msgRetention = "true";
String port = "";
String queueManager = "";
String tempModel = "";
String transportType = "CLIENT";
}
private String myJmsProvider = "WebSphere MQ JMS Provider";
private Args myCurrent = null;
/**
* @param namespaceURI -
* @param sName -
* @param qName -
* @param attrs -
*
* @throws SAXException -
*/
public void startElement(String namespaceURI, String sName, String qName, Attributes attrs) throws SAXException {
String name = attrs.getValue("name");
if ("qcf".equals(qName)) {
myCurrent = new Args();
myCurrent.node = getGlobal("node") != null ? getGlobal("node") : myCurrent.node;
myCurrent.server = getGlobal("server") != null ? getGlobal("server") : myCurrent.server;
myCurrent.CCSID = getGlobal("CCSID") != null ? getGlobal("CCSID") : myCurrent.CCSID;
myCurrent.XAEnabled = getGlobal("XAEnabled") != null ? getGlobal("XAEnabled") : myCurrent.XAEnabled;
myCurrent.authDataAlias = getGlobal("authDataAlias") != null ? getGlobal("authDataAlias") : myCurrent.authDataAlias;
myCurrent.authMechanismPreference = getGlobal("authMechanismPreference") != null ? getGlobal("authMechanismPreference") : myCurrent.authMechanismPreference;
myCurrent.category = getGlobal("category") != null ? getGlobal("category") : myCurrent.category;
myCurrent.channel = getGlobal("channel") != null ? getGlobal("channel") : myCurrent.channel;
myCurrent.clientID = getGlobal("clientID") != null ? getGlobal("clientID") : myCurrent.clientID;
myCurrent.host = getGlobal("host") != null ? getGlobal("host") : myCurrent.host;
myCurrent.mappingConfigAlias = getGlobal("mappingConfigAlias") != null ? getGlobal("mappingConfigAlias") : myCurrent.mappingConfigAlias;
myCurrent.msgRetention = getGlobal("msgRetention") != null ? getGlobal("msgRetention") : myCurrent.msgRetention;
myCurrent.port = getGlobal("port") != null ? getGlobal("port") : myCurrent.port;
myCurrent.queueManager = getGlobal("queueManager") != null ? getGlobal("queueManager") : myCurrent.queueManager;
myCurrent.tempModel = getGlobal("tempModel") != null ? getGlobal("tempModel") : myCurrent.tempModel;
myCurrent.transportType = getGlobal("transportType") != null ? getGlobal("transportType") : myCurrent.transportType;
addArgs(myCurrent);
} else if ("node".equals(qName)) {
if (myCurrent == null) {
addGlobal("node", name);
} else {
myCurrent.node = name;
}
} else if ("server".equals(qName)) {
if (myCurrent == null) {
addGlobal("server", name);
} else {
myCurrent.server = name;
}
} else if ("CCSID".equals(qName)) {
if (myCurrent == null) {
addGlobal("CCSID", name);
} else {
myCurrent.CCSID = name;
}
} else if ("XAEnabled".equals(qName)) {
if (myCurrent == null) {
addGlobal("XAEnabled", name);
} else {
myCurrent.XAEnabled = name;
}
} else if ("authDataAlias".equals(qName)) {
if (myCurrent == null) {
addGlobal("authDataAlias", name);
} else {
myCurrent.authDataAlias = name;
}
} else if ("authMechanismPreference".equals(qName)) {
if (myCurrent == null) {
addGlobal("authMechanismPreference", name);
} else {
myCurrent.authMechanismPreference = name;
}
} else if ("category".equals(qName)) {
if (myCurrent == null) {
addGlobal("category", name);
} else {
myCurrent.category = name;
}
} else if ("channel".equals(qName)) {
if (myCurrent == null) {
addGlobal("channel", name);
} else {
myCurrent.channel = name;
}
} else if ("clientID".equals(qName)) {
if (myCurrent == null) {
addGlobal("clientID", name);
} else {
myCurrent.clientID = name;
}
} else if ("host".equals(qName)) {
if (myCurrent == null) {
addGlobal("host", name);
} else {
myCurrent.host = name;
}
} else if ("mappingConfigAlias".equals(qName)) {
if (myCurrent == null) {
addGlobal("mappingConfigAlias", name);
} else {
myCurrent.mappingConfigAlias = name;
}
} else if ("msgRetention".equals(qName)) {
if (myCurrent == null) {
addGlobal("msgRetention", name);
} else {
myCurrent.msgRetention = name;
}
} else if ("port".equals(qName)) {
if (myCurrent == null) {
addGlobal("port", name);
} else {
myCurrent.port = name;
}
} else if ("queueManager".equals(qName)) {
if (myCurrent == null) {
addGlobal("queueManager", name);
} else {
myCurrent.queueManager = name;
}
} else if ("tempModel".equals(qName)) {
if (myCurrent == null) {
addGlobal("tempModel", name);
} else {
myCurrent.tempModel = name;
}
} else if ("transportType".equals(qName)) {
if (myCurrent == null) {
addGlobal("transportType", name);
} else {
myCurrent.transportType = name;
}
} else if ("name".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.name = name;
} else if ("jndiName".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.jndiName = name;
} else if ("description".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.description = name;
}
}
protected String generateFile() {
try {
File file = File.createTempFile("wsant", "jacl");
PrintWriter printwriter = new PrintWriter(new FileWriter(file));
addDefaultHeader(printwriter);
for (Iterator iter = getArgs().iterator(); iter.hasNext();) {
Args args = (Args) iter.next();
required(args.name, "name");
required(args.jndiName, "jndiName");
required(args.transportType, "transportType");
String path = "/Cell:$cell";
if (args.node != null && !args.node.trim().equals("")) {
path = path + "/Node:" + args.node;
}
if (args.server != null && !args.server.trim().equals("")) {
path = path + "/Server:" + args.server;
}
path = path + "/JMSProvider:" + myJmsProvider + "/";
printwriter.println("set jmsp [$AdminConfig getid \"" + path + "\"]");
printwriter.println("puts \"Creating MQ QCF " + args.name + "\"");
String attrs = "{name " + StringUtil.wrap(args.name) + "} {jndiName " + StringUtil.wrap(args.jndiName) + "} {transportType " + StringUtil.wrap(args.transportType) + "}";
if(!args.description.equals("")) {
attrs = attrs + " {description " + StringUtil.wrap(args.description) + "}";
}
if(!args.CCSID.equals("")) {
attrs = attrs + " {CCSID " + StringUtil.wrap(args.CCSID) + "}";
}
if(!args.XAEnabled.equals("")) {
attrs = attrs + " {XAEnabled " + StringUtil.wrap(args.XAEnabled) + "}";
}
if(!args.category.equals("")) {
attrs = attrs + " {category " + StringUtil.wrap(args.category) + "}";
}
if(!args.channel.equals("")) {
attrs = attrs + " {channel " + StringUtil.wrap(args.channel) + "}";
}
if(!args.clientID.equals("")) {
attrs = attrs + " {clientID " + StringUtil.wrap(args.clientID) + "}";
}
if(!args.host.equals("")) {
attrs = attrs + " {host " + StringUtil.wrap(args.host) + "}";
}
if(!args.msgRetention.equals("")) {
attrs = attrs + " {msgRetention " + StringUtil.wrap(args.msgRetention) + "}";
}
if(!args.port.equals("")) {
attrs = attrs + " {port " + StringUtil.wrap(args.port) + "}";
}
if(!args.queueManager.equals("")) {
attrs = attrs + " {queueManager " + StringUtil.wrap(args.queueManager) + "}";
}
if(!args.tempModel.equals("")) {
attrs = attrs + " {tempModel " + StringUtil.wrap(args.tempModel) + "}";
}
if(!args.authMechanismPreference.equals("")) {
attrs = attrs + " {authMechanismPreference " + StringUtil.wrap(args.authMechanismPreference) + "}";
}
printwriter.println("set attrs [list " + attrs + "]");
printwriter.println("set qcf [$AdminConfig create MQQueueConnectionFactory $jmsp $attrs]");
String mappings = "";
if (!args.authDataAlias.equals("")) {
mappings = "{authDataAlias " + StringUtil.wrap(args.authDataAlias) + "}";
}
if (!args.mappingConfigAlias.equals("")) {
mappings = mappings + " {mappingConfigAlias " + StringUtil.wrap(args.mappingConfigAlias) + "}";
}
if (!mappings.equals("")) {
printwriter.println("set mappedAlias [$AdminConfig create MappingModule $qcf [subst {" + mappings + "}] mapping]");
}
printwriter.println("$AdminConfig create ConnectionPool $qcf {} connectionPool");
printwriter.println("$AdminConfig save");
}
printwriter.println("puts \"Created " + getArgs().size() + "\"");
printwriter.flush();
printwriter.close();
return file.getAbsolutePath();
} catch (Throwable t) {
return t.getMessage();
}
}
public void endElement(String uri, String localName, String qName) throws SAXException {
if ("qcf".equals(qName)) {
myCurrent = null;
}
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/mq/QueueHandler.java
Index: QueueHandler.java
===================================================================
package org.apache.maven.was5.mq;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.util.Iterator;
import org.apache.maven.was5.ScriptFileHandler;
import org.apache.maven.was5.StringUtil;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
/**
*
* @author Morten Kristiansen
*/
public class QueueHandler extends ScriptFileHandler {
class Args {
String node = "";
String server = "";
String name = "";
String jndiName = "";
String description = "";
String CCSID = "";
String baseQueueManagerName = "";
String baseQueueName = "";
String category = "";
String decimalEncoding = "Normal";
String expiry = "APPLICATION_DEFINED";
String floatingPointEncoding = "IEEENormal";
String integerEncoding = "Normal";
String password = "";
String persistence = "APPLICATION_DEFINED";
String priority = "APPLICATION_DEFINED";
String queueManagerHost = "";
String queueManagerPort = "0";
String serverConnectionChannelName = "";
String specifiedExpiry = "0";
String specifiedPriority = "0";
String targetClient = "JMS";
String useNativeEncoding = "false";
String userName = "";
}
private String myJmsProvider = "WebSphere MQ JMS Provider";
private Args myCurrent = null;
/**
* @param namespaceURI -
* @param sName -
* @param qName -
* @param attrs -
*
* @throws SAXException -
*/
public void startElement(String namespaceURI, String sName, String qName, Attributes attrs) throws SAXException {
String name = attrs.getValue("name");
if ("queue".equals(qName)) {
myCurrent = new Args();
myCurrent.node = getGlobal("node") != null ? getGlobal("node") : myCurrent.node;
myCurrent.server = getGlobal("server") != null ? getGlobal("server") : myCurrent.server;
myCurrent.CCSID = getGlobal("CCSID") != null ? getGlobal("CCSID") : myCurrent.CCSID;
myCurrent.baseQueueManagerName =
getGlobal("baseQueueManagerName") != null ? getGlobal("baseQueueManagerName") : myCurrent.baseQueueManagerName;
myCurrent.baseQueueName = getGlobal("baseQueueName") != null ? getGlobal("baseQueueName") : myCurrent.baseQueueName;
myCurrent.category = getGlobal("category") != null ? getGlobal("category") : myCurrent.category;
myCurrent.decimalEncoding = getGlobal("decimalEncoding") != null ? getGlobal("decimalEncoding") : myCurrent.decimalEncoding;
myCurrent.expiry = getGlobal("expiry") != null ? getGlobal("expiry") : myCurrent.expiry;
myCurrent.floatingPointEncoding =
getGlobal("floatingPointEncoding") != null ? getGlobal("floatingPointEncoding") : myCurrent.floatingPointEncoding;
myCurrent.integerEncoding = getGlobal("integerEncoding") != null ? getGlobal("integerEncoding") : myCurrent.integerEncoding;
myCurrent.password = getGlobal("password") != null ? getGlobal("password") : myCurrent.password;
myCurrent.persistence = getGlobal("persistence") != null ? getGlobal("persistence") : myCurrent.persistence;
myCurrent.priority = getGlobal("priority") != null ? getGlobal("priority") : myCurrent.priority;
myCurrent.queueManagerHost = getGlobal("queueManagerHost") != null ? getGlobal("queueManagerHost") : myCurrent.queueManagerHost;
myCurrent.queueManagerPort = getGlobal("queueManagerPort") != null ? getGlobal("queueManagerPort") : myCurrent.queueManagerPort;
myCurrent.serverConnectionChannelName =
getGlobal("serverConnectionChannelName") != null
? getGlobal("serverConnectionChannelName")
: myCurrent.serverConnectionChannelName;
myCurrent.specifiedExpiry = getGlobal("specifiedExpiry") != null ? getGlobal("specifiedExpiry") : myCurrent.specifiedExpiry;
myCurrent.specifiedPriority =
getGlobal("specifiedPriority") != null ? getGlobal("specifiedPriority") : myCurrent.specifiedPriority;
myCurrent.targetClient = getGlobal("targetClient") != null ? getGlobal("targetClient") : myCurrent.targetClient;
myCurrent.useNativeEncoding =
getGlobal("useNativeEncoding") != null ? getGlobal("useNativeEncoding") : myCurrent.useNativeEncoding;
myCurrent.userName = getGlobal("userName") != null ? getGlobal("userName") : myCurrent.userName;
addArgs(myCurrent);
} else if ("node".equals(qName)) {
if (myCurrent == null) {
addGlobal("node", name);
} else {
myCurrent.node = name;
}
} else if ("server".equals(qName)) {
if (myCurrent == null) {
addGlobal("server", name);
} else {
myCurrent.server = name;
}
} else if ("CCSID".equals(qName)) {
if (myCurrent == null) {
addGlobal("CCSID", name);
} else {
myCurrent.CCSID = name;
}
} else if ("baseQueueManagerName".equals(qName)) {
if (myCurrent == null) {
addGlobal("baseQueueManagerName", name);
} else {
myCurrent.baseQueueManagerName = name;
}
} else if ("baseQueueName".equals(qName)) {
if (myCurrent == null) {
addGlobal("baseQueueName", name);
} else {
myCurrent.baseQueueName = name;
}
} else if ("category".equals(qName)) {
if (myCurrent == null) {
addGlobal("category", name);
} else {
myCurrent.category = name;
}
} else if ("decimalEncoding".equals(qName)) {
if (myCurrent == null) {
addGlobal("decimalEncoding", name);
} else {
myCurrent.decimalEncoding = name;
}
} else if ("expiry".equals(qName)) {
if (myCurrent == null) {
addGlobal("expiry", name);
} else {
myCurrent.expiry = name;
}
} else if ("floatingPointEncoding".equals(qName)) {
if (myCurrent == null) {
addGlobal("floatingPointEncoding", name);
} else {
myCurrent.floatingPointEncoding = name;
}
} else if ("integerEncoding".equals(qName)) {
if (myCurrent == null) {
addGlobal("integerEncoding", name);
} else {
myCurrent.integerEncoding = name;
}
} else if ("password".equals(qName)) {
if (myCurrent == null) {
addGlobal("password", name);
} else {
myCurrent.password = name;
}
} else if ("persistence".equals(qName)) {
if (myCurrent == null) {
addGlobal("persistence", name);
} else {
myCurrent.persistence = name;
}
} else if ("priority".equals(qName)) {
if (myCurrent == null) {
addGlobal("priority", name);
} else {
myCurrent.priority = name;
}
} else if ("queueManagerHost".equals(qName)) {
if (myCurrent == null) {
addGlobal("queueManagerHost", name);
} else {
myCurrent.queueManagerHost = name;
}
} else if ("queueManagerPort".equals(qName)) {
if (myCurrent == null) {
addGlobal("queueManagerPort", name);
} else {
myCurrent.queueManagerPort = name;
}
} else if ("serverConnectionChannelName".equals(qName)) {
if (myCurrent == null) {
addGlobal("serverConnectionChannelName", name);
} else {
myCurrent.serverConnectionChannelName = name;
}
} else if ("specifiedExpiry".equals(qName)) {
if (myCurrent == null) {
addGlobal("specifiedExpiry", name);
} else {
myCurrent.specifiedExpiry = name;
}
} else if ("specifiedPriority".equals(qName)) {
if (myCurrent == null) {
addGlobal("specifiedPriority", name);
} else {
myCurrent.specifiedPriority = name;
}
} else if ("targetClient".equals(qName)) {
if (myCurrent == null) {
addGlobal("targetClient", name);
} else {
myCurrent.targetClient = name;
}
} else if ("useNativeEncoding".equals(qName)) {
if (myCurrent == null) {
addGlobal("useNativeEncoding", name);
} else {
myCurrent.useNativeEncoding = name;
}
} else if ("userName".equals(qName)) {
if (myCurrent == null) {
addGlobal("userName", name);
} else {
myCurrent.userName = name;
}
} else if ("name".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.name = name;
} else if ("jndiName".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.jndiName = name;
} else if ("description".equals(qName)) {
if(myCurrent == null) {
throw new SAXException("Invalid global found");
}
myCurrent.description = name;
}
}
protected String generateFile() {
try {
File file = File.createTempFile("wsant", "jacl");
PrintWriter printwriter = new PrintWriter(new FileWriter(file));
addDefaultHeader(printwriter);
for (Iterator iter = getArgs().iterator(); iter.hasNext();) {
Args args = (Args) iter.next();
required(args.name, "name");
required(args.jndiName, "jndiName");
required(args.baseQueueName, "baseQueueName");
String path = "/Cell:$cell";
if (args.node != null && !args.node.trim().equals("")) {
path = path + "/Node:" + args.node;
}
if (args.server != null && !args.server.trim().equals("")) {
path = path + "/Server:" + args.server;
}
path = path + "/JMSProvider:" + myJmsProvider + "/";
printwriter.println("set jmsp [$AdminConfig getid \"" + path + "\"]");
printwriter.println("puts \"Creating MQ QUEUE " + args.name + "\"");
String attrs = "{name " + StringUtil.wrap(args.name) + "} {jndiName " + StringUtil.wrap(args.jndiName) + "} {baseQueueName " + StringUtil.wrap(args.baseQueueName) + "}";
if(!args.description.equals("")) {
attrs = attrs + " {description " + StringUtil.wrap(args.description) + "}";
}
if(!args.CCSID.equals("")) {
attrs = attrs + " {CCSID " + StringUtil.wrap(args.CCSID) + "}";
}
if(!args.baseQueueManagerName.equals("")) {
attrs = attrs + " {baseQueueManagerName " + StringUtil.wrap(args.baseQueueManagerName) + "}";
}
if(!args.category.equals("")) {
attrs = attrs + " {category " + StringUtil.wrap(args.category) + "}";
}
if(!args.decimalEncoding.equals("")) {
attrs = attrs + " {decimalEncoding " + StringUtil.wrap(args.decimalEncoding) + "}";
}
if(!args.expiry.equals("")) {
attrs = attrs + " {expiry " + StringUtil.wrap(args.expiry) + "}";
}
if(!args.floatingPointEncoding.equals("")) {
attrs = attrs + " {floatingPointEncoding " + StringUtil.wrap(args.floatingPointEncoding) + "}";
}
if(!args.integerEncoding.equals("")) {
attrs = attrs + " {integerEncoding " + StringUtil.wrap(args.integerEncoding) + "}";
}
if(!args.password.equals("")) {
attrs = attrs + " {password " + StringUtil.wrap(args.password) + "}";
}
if(!args.persistence.equals("")) {
attrs = attrs + " {persistence " + StringUtil.wrap(args.persistence) + "}";
}
if(!args.priority.equals("")) {
attrs = attrs + " {priority " + StringUtil.wrap(args.priority) + "}";
}
if(!args.queueManagerHost.equals("")) {
attrs = attrs + " {queueManagerHost " + StringUtil.wrap(args.queueManagerHost) + "}";
}
if(!args.queueManagerPort.equals("")) {
attrs = attrs + " {queueManagerPort " + StringUtil.wrap(args.queueManagerPort) + "}";
}
if(!args.serverConnectionChannelName.equals("")) {
attrs = attrs + " {serverConnectionChannelName " + StringUtil.wrap(args.serverConnectionChannelName) + "}";
}
if(!args.specifiedExpiry.equals("")) {
attrs = attrs + " {specifiedExpiry " + StringUtil.wrap(args.specifiedExpiry) + "}";
}
if(!args.specifiedPriority.equals("")) {
attrs = attrs + " {specifiedPriority " + StringUtil.wrap(args.specifiedPriority) + "}";
}
if(!args.targetClient.equals("")) {
attrs = attrs + " {targetClient " + StringUtil.wrap(args.targetClient) + "}";
}
if(!args.useNativeEncoding.equals("")) {
attrs = attrs + " {useNativeEncoding " + StringUtil.wrap(args.useNativeEncoding) + "}";
}
if(!args.userName.equals("")) {
attrs = attrs + " {userName " + StringUtil.wrap(args.userName) + "}";
}
printwriter.println("set attrs [list " + attrs + "]");
printwriter.println("$AdminConfig create MQQueue $jmsp $attrs");
printwriter.println("$AdminConfig save");
}
printwriter.println("puts \"Created " + getArgs().size() + "\"");
printwriter.flush();
printwriter.close();
return file.getAbsolutePath();
} catch (Throwable t) {
return t.getMessage();
}
}
public void endElement(String uri, String localName, String qName) throws SAXException {
if ("queue".equals(qName)) {
myCurrent = null;
}
}
}
1.1 maven-plugins/was5config/src/java/org/apache/maven/was5/mq/TCFHandler.java
Index: TCFHandler.java
===================================================================
package org.apache.maven.was5.mq;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.util.Iterator;
import org.apache.maven.was5.ScriptFileHandler;
import org.apache.maven.was5.StringUtil;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
/**
*
* @author Bjorn Hilstad
*/
public class TCFHandler extends ScriptFileHandler {
class Args {
String node = "";
String server = "";
String name = "";
String jndiName = "";
String description = "";
String CCSID = "";
String XAEnabled = "true";
String authDataAlias = "";
String authMechanismPreference = "";
String brokerCCSubQ = "";
String brokerControlQueue = "";
String brokerPubQueue = "";
String brokerQueueManager = "";
String brokerSubQueue = "";
String brokerVersion = "MA0C";
String category = "";
String channel = "";
String clientID = "";
String cloneSupport = "false";
String host = "";
String port = "";
String mapping = "DefaultPrincipalMapping";
String queueManager = "";
String tempModel = "";
String transportType = "BINDINGS";
}
private String myJmsProvider = "WebSphere MQ JMS Provider";
private Args myCurrent = null;
/**
* @param namespaceURI -
* @param sName -
* @param tName -
* @param attrs -
*
* @throws SAXException -
*/
public void startElement(String namespaceURI, String sName, String tName, Attributes attrs) throws SAXException {
String name = attrs.getValue("name");
if ("tcf".equals(tName)) {
myCurrent = new Args();
myCurrent.node = getGlobal("node") != null ? getGlobal("node") : myCurrent.node;
myCurrent.server = getGlobal("server") != null ? getGlobal("server") : myCurrent.server;
myCurrent.CCSID = getGlobal("CCSID") != null ? getGlobal("CCSID") : myCurrent.CCSID;
myCurrent.XAEnabled = getGlobal("XAEnabled") != null ? getGlobal("XAEnabled") : myCurrent.XAEnabled;
myCurrent.authDataAlias = getGlobal("authDataAlias") != null ? getGlobal("authDataAlias") : myCurrent.authDataAlias;
myCurrent.authMechanismPreference = getGlobal("authMechanismPreference") != null ? getGlobal("authMechanismPreference") : myCurrent.authMechanismPreference;
myCurrent.brokerCCSubQ = getGlobal("brokerCCSubQ") != null ? getGlobal("brokerCCSubQ") : myCurrent.brokerCCSubQ;
myCurrent.brokerControlQueue = getGlobal("brokerControlQueue") != null ? getGlobal("brokerControlQueue") : myCurrent.brokerControlQueue;
myCurrent.brokerPubQueue = getGlobal("brokerPubQueue") != null ? getGlobal("brokerPubQueue") : myCurrent.brokerPubQueue;
myCurrent.brokerQueueManager = getGlobal("brokerQueueManager") != null ? getGlobal("brokerQueueManager") : myCurrent.brokerQueueManager;
myCurrent.brokerSubQueue = getGlobal("brokerSubQueue") != null ? getGlobal("brokerSubQueue") : myCurrent.brokerSubQueue;
myCurrent.brokerVersion = getGlobal("brokerVersion") != null ? getGlobal("brokerVersion") : myCurrent.brokerVersion;
myCurrent.category = getGlobal("category") != null ? getGlobal("category") : myCurrent.category;
myCurrent.channel = getGlobal("channel") != null ? getGlobal("channel") : myCurrent.channel;
myCurrent.clientID = getGlobal("clientID") != null ? getGlobal("clientID") : myCurrent.clientID;
myCurrent.cloneSupport = getGlobal("cloneSupport") != null ? getGlobal("cloneSupport") : myCurrent.cloneSupport;
myCurrent.host = getGlobal("host") != null ? getGlobal("host") : myCurrent.host;
myCurrent.port = getGlobal("port") != null ? getGlobal("port") : myCurrent.port;
myCurrent.mapping = getGlobal("mapping") != null ? getGlobal("mapping") : myCurrent.mapping;
myCurrent.queueManager = getGlobal("queueManager") != null ? getGlobal("queueManager") : myCurrent.queueManager;
myCurrent.tempModel = getGlobal("tempModel") != null ? getGlobal("tempModel") : myCurrent.tempModel;
myCurrent.transportType = getGlobal("transportType") != null ? getGlobal("transportType") : myCurrent.transportType;
addArgs(myCurrent);
} else if ("node".equals(tName)) {
if (myCurrent == null) {
addGlobal("node", name);
} else {
myCurrent.node = name;
}
} else if ("server".equals(tName)) {
if (myCurrent == null) {
addGlobal("server", name);
} else {
myCurrent.server = name;
}
} else if ("CCSID".equals(tName)) {
if (myCurrent == null) {
addGlobal("CCSID", name);
} else {
myCurrent.CCSID = name;
}
} else if ("XAEnabled".equals(tName)) {
if (myCurrent == null) {
addGlobal("XAEnabled", name);
} else {
myCurrent.XAEnabled = name;
}
} else if ("authDataAlias".equals(tName)) {
if (myCurrent == null) {
addGlobal("authDataAlias", name);
} else {
myCurrent.authDataAlias = name;
}
} else if ("authMechanismPreference".equals(tName)) {
if (myCurrent == null) {
addGlobal("authMechanismPreference", name);
} else {
myCurrent.authMechanismPreference = name;
}
} else if ("brokerCCSubQ".equals(tName)) {
if (myCurrent == null) {
addGlobal("brokerCCSubQ", name);
} else {
myCurrent.brokerCCSubQ = name;
}
} else if ("brokerControlQueue".equals(tName)) {
if (myCurrent == null) {
addGlobal("brokerControlQueue", name);
} else {
myCurrent.brokerControlQueue = name;
}
} else if ("brokerPubQueue".equals(tName)) {
if (myCurrent == null) {
addGlobal("brokerPubQueue", name);
} else {
myCurrent.brokerPubQueue = name;
}
} else if ("brokerQueueManager".equals(tName)) {
if (myCurrent == null) {
addGlobal("brokerQueueManager", name);
} else {
myCurrent.brokerQueueManager = name;
}
} else if ("brokerSubQueue".equals(tName)) {
if (myCurrent == null) {
addGlobal("brokerSubQueue", name);
} else {
myCurrent.brokerSubQueue = name;
}
} else if ("brokerVersion".equals(tName)) {
if (myCurrent == null) {
addGlobal("brokerVersion", name);
} else {
myCurrent.brokerVersion = name;
}
} else if ("category".equals(tName)) {
if (myCurrent == null) {
addGlobal("category", name);
} else {
myCurrent.category = name;
}
} else if ("channel".equals(tName)) {
if (myCurrent == null) {
addGlobal("channel", name);
} else {
myCurrent.channel = name;
}
} else if ("clientID".equals(tName)) {
if (myCurrent == null) {
addGlobal("clientID", name);
} el...
[truncated message content] |
