http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/8315f8fa/core/src/flex/messaging/config/ServletResourceResolver.java ---------------------------------------------------------------------- diff --git a/core/src/flex/messaging/config/ServletResourceResolver.java b/core/src/flex/messaging/config/ServletResourceResolver.java deleted file mode 100644 index b79bc27..0000000 --- a/core/src/flex/messaging/config/ServletResourceResolver.java +++ /dev/null @@ -1,156 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package flex.messaging.config; - -import flex.messaging.io.ArrayList; - -import javax.servlet.ServletContext; -import java.io.IOException; -import java.io.InputStream; -import java.util.Collections; -import java.util.Iterator; -import java.util.List; -import java.util.Set; -import java.util.Stack; - -/** - * - */ -public class ServletResourceResolver implements ConfigurationFileResolver -{ - private ServletContext context; - private Stack configurationPathStack = new Stack(); - - /** - * Constructor. - * - * @param context servlet context - */ - public ServletResourceResolver(ServletContext context) - { - this.context = context; - } - - /** - * Is the configuration file available. - * - * @param path path to check - * @param throwError true if wmethod shold throw a ConfigurationException if path no found. - * @return true if path is available - * @throws ConfigurationException if throwError is true and path is not available - */ - public boolean isAvailable(String path, boolean throwError) throws ConfigurationException - { - boolean available = false; - InputStream is = context.getResourceAsStream(path); - if (is != null) - { - try { is.close(); } catch (IOException ignore) { /* ignore */} - pushConfigurationFile(path); - available = true; - } - else - { - if (throwError) - { - // Please specify a valid ''services.configuration.file'' in web.xml. - ConfigurationException e = new ConfigurationException(); - e.setMessage(11108, new Object[] {path}); - throw e; - } - } - - return available; - } - - public InputStream getConfigurationFile(String path) - { - InputStream is = context.getResourceAsStream(path); - if (is != null) - { - pushConfigurationFile(path); - return is; - } - else - { - // Please specify a valid ''services.configuration.file'' in web.xml. - ConfigurationException e = new ConfigurationException(); - e.setMessage(11108, new Object[] {path}); - throw e; - } - } - - public InputStream getIncludedFile(String src) - { - String path = configurationPathStack.peek() + "/" + src; - InputStream is = context.getResourceAsStream(path); - - if (is != null) - { - pushConfigurationFile(path); - return is; - } - else - { - // Please specify a valid include file. ''{0}'' is invalid. - ConfigurationException e = new ConfigurationException(); - e.setMessage(11107, new Object[] {path}); - throw e; - } - } - - public void popIncludedFile() - { - configurationPathStack.pop(); - } - - /** - * Returns the list of XML files (denoted by .xml extension) in the directory - * relative to the current configuration file. - */ - public List getFiles(String dir) - { - List result = new ArrayList(); - String prefix = configurationPathStack.peek() + "/"; - Set paths = context.getResourcePaths(prefix + dir); - if (paths != null) - { - for (Object entry : paths) - { - String path = (String) entry; - if (path.endsWith(".xml")) - { - result.add(path.substring(prefix.length())); - } - } - return result; - } - else - { - // Please specify a valid include directory. ''{0}'' is invalid. - ConfigurationException e = new ConfigurationException(); - e.setMessage(11113, new Object[]{dir}); - throw e; - } - } - - private void pushConfigurationFile(String path) - { - String topLevelPath = path.substring(0, path.lastIndexOf('/')); - configurationPathStack.push(topLevelPath); - } -}
http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/8315f8fa/core/src/flex/messaging/config/SharedServerSettings.java ---------------------------------------------------------------------- diff --git a/core/src/flex/messaging/config/SharedServerSettings.java b/core/src/flex/messaging/config/SharedServerSettings.java deleted file mode 100644 index 8fe815a..0000000 --- a/core/src/flex/messaging/config/SharedServerSettings.java +++ /dev/null @@ -1,65 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package flex.messaging.config; - -/** - * Stores configuration settings for a shared server instance. - * <tt>ServerConfigurationParser</tt> will generate an instance for each shared server - * defined in the configuration file. - * The <tt>MessagingConfiguration</tt> instance using the parser will store these and - * use them to configure the <tt>MessageBroker</tt> with shared server instances. - * - * - */ -public class SharedServerSettings extends PropertiesSettings -{ - private String id; - - public String getId() - { - return id; - } - - public void setId(String value) - { - id = value; - } - - private String className; - - public String getClassName() - { - return className; - } - - public void setClassName(String value) - { - className = value; - } - - private String sourceFile; - - public String getSourceFile() - { - return sourceFile; - } - - public void setSourceFile(String value) - { - sourceFile = value; - } -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/8315f8fa/core/src/flex/messaging/config/SystemSettings.java ---------------------------------------------------------------------- diff --git a/core/src/flex/messaging/config/SystemSettings.java b/core/src/flex/messaging/config/SystemSettings.java deleted file mode 100644 index cf4cd49..0000000 --- a/core/src/flex/messaging/config/SystemSettings.java +++ /dev/null @@ -1,300 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package flex.messaging.config; - -import flex.messaging.log.Log; -import flex.messaging.log.Logger; -import flex.messaging.util.PropertyStringResourceLoader; -import flex.messaging.util.ResourceLoader; -import flex.messaging.util.WatchedObject; - -import java.io.File; -import java.io.FileNotFoundException; -import java.util.ArrayList; -import java.util.List; -import java.util.Locale; - -import javax.servlet.ServletContext; - -/** - * - */ -public class SystemSettings -{ - private ResourceLoader resourceLoader; - private Locale defaultLocale; - private boolean enforceEndpointValidation; - private boolean manageable; - private boolean redeployEnabled; - private int watchInterval; - private List watches; - private List touches; - private String uuidGeneratorClassName; - private String dotNetFrameworkVersion; - - public SystemSettings() - { - enforceEndpointValidation = false; - manageable = true; - redeployEnabled = false; - resourceLoader = new PropertyStringResourceLoader(); - touches = new ArrayList(); - watches = new ArrayList(); - watchInterval = 20; - dotNetFrameworkVersion = null; - } - - public void setDefaultLocale(Locale locale) - { - defaultLocale = locale; - resourceLoader.setDefaultLocale(defaultLocale); - } - - public Locale getDefaultLocale() - { - return defaultLocale; - } - - public boolean isManageable() - { - return manageable; - } - - public void setManageable(String manageable) - { - manageable = manageable.toLowerCase(); - if (manageable.startsWith("f")) - this.manageable = false; - } - - public boolean isEnforceEndpointValidation() - { - return enforceEndpointValidation; - } - - public void setEnforceEndpointValidation(String enforceEndpointValidation) - { - if (enforceEndpointValidation == null || enforceEndpointValidation.length() == 0) - return; - if (enforceEndpointValidation.toLowerCase().startsWith("t")) - this.enforceEndpointValidation = true; - } - - public ResourceLoader getResourceLoader() - { - return resourceLoader; - } - - public void setResourceLoader(ResourceLoader resourceLoader) - { - this.resourceLoader = resourceLoader; - } - - public void setRedeployEnabled(String enabled) - { - enabled = enabled.toLowerCase(); - if (enabled.startsWith("t")) - this.redeployEnabled = true; - } - - public boolean getRedeployEnabled() - { - return redeployEnabled; - } - - public void setWatchInterval(String interval) - { - this.watchInterval = Integer.parseInt(interval); - } - - public int getWatchInterval() - { - return watchInterval; - } - - public void addWatchFile(String watch) - { - this.watches.add(watch); - } - - public List getWatchFiles() - { - return watches; - } - - public void addTouchFile(String touch) - { - this.touches.add(touch); - } - - public List getTouchFiles() - { - return touches; - } - - public void setPaths(ServletContext context) - { - if (redeployEnabled) - { - List resolvedWatches = new ArrayList(); - for (int i = 0; i < watches.size(); i++) - { - String path = (String)watches.get(i); - String resolvedPath = null; - if (path.startsWith("{context.root}") || path.startsWith("{context-root}")) - { - path = path.substring(14); - resolvedPath = context.getRealPath(path); - - if (resolvedPath != null) - { - try - { - resolvedWatches.add(new WatchedObject(resolvedPath)); - } - catch (FileNotFoundException fnfe) - { - Logger logger = Log.getLogger(ConfigurationManager.LOG_CATEGORY); - if (logger != null) - { - logger.warn("The watch-file, " + path + ", could not be found and will be ignored."); - } - } - } - else - { - Logger logger = Log.getLogger(ConfigurationManager.LOG_CATEGORY); - logger.warn("The watch-file, " + path + ", could not be resolved to a path and will be ignored."); - } - } - else - { - try - { - resolvedWatches.add(new WatchedObject(path)); - } - catch (FileNotFoundException fnfe) - { - Logger logger = Log.getLogger(ConfigurationManager.LOG_CATEGORY); - if (logger != null) - { - logger.warn("The watch-file, " + path + ", could not be found and will be ignored."); - } - } - } - } - watches = resolvedWatches; - - List resolvedTouches = new ArrayList(); - for (int i = 0; i < touches.size(); i++) - { - String path = (String)touches.get(i); - String resolvedPath = null; - if (path.startsWith("{context.root}") || path.startsWith("{context-root}")) - { - path = path.substring(14); - resolvedPath = context.getRealPath(path); - - if (resolvedPath != null) - { - File file = new File(resolvedPath); - if (!file.exists() || (!file.isFile() && !file.isDirectory()) || (!file.isAbsolute())) - { - Logger logger = Log.getLogger(ConfigurationManager.LOG_CATEGORY); - logger.warn("The touch-file, " + path + ", could not be found and will be ignored."); - } - else - { - resolvedTouches.add(resolvedPath); - } - } - else - { - Logger logger = Log.getLogger(ConfigurationManager.LOG_CATEGORY); - logger.warn("The touch-file, " + path + ", could not be resolved to a path and will be ignored."); - } - } - else - { - try - { - resolvedTouches.add(new WatchedObject(path)); - } - catch (FileNotFoundException fnfe) - { - Logger logger = Log.getLogger(ConfigurationManager.LOG_CATEGORY); - if (logger != null) - { - logger.warn("The touch-file, " + path + ", could not be found and will be ignored."); - } - } - } - } - touches = resolvedTouches; - } - } - - /** - * Returns the UUID generator class name. - * - * @return The UUID generator class name. - */ - public String getUUIDGeneratorClassName() - { - return uuidGeneratorClassName; - } - - /** - * Sets the UUID generator class name. - * - * @param value The UUID generator class name. - */ - public void setUUIDGeneratorClassName(String value) - { - uuidGeneratorClassName = value; - } - - /** - * Set the dotnet framework version to use. - * @param version the configured dotnet framework version - */ - public void setDotNetFrameworkVersion(String version) - { - dotNetFrameworkVersion = version; - } - - /** - * Get the dotnet framework version. - * @return String the dotnet framework version - */ - public String getDotNetFrameworkVersion() - { - return dotNetFrameworkVersion; - } - /** - * Clean up static member variables. - */ - public void clear() - { - resourceLoader = null; - defaultLocale = null; - watches = null; - touches = null; - dotNetFrameworkVersion = null; - } - -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/8315f8fa/core/src/flex/messaging/config/ThrottleSettings.java ---------------------------------------------------------------------- diff --git a/core/src/flex/messaging/config/ThrottleSettings.java b/core/src/flex/messaging/config/ThrottleSettings.java deleted file mode 100644 index 96b5a3b..0000000 --- a/core/src/flex/messaging/config/ThrottleSettings.java +++ /dev/null @@ -1,373 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package flex.messaging.config; - -/** - * This configuration class is derived from optional properties that - * may be supplied in the <properties> section of a destination. - * It exists to capture properties related to message throttling in a way - * that simplifies the ThrottleManager's usage of the configuration. - */ -public class ThrottleSettings -{ - /** - * The Policy enum. - */ - public enum Policy - { - NONE, - ERROR, - IGNORE, - BUFFER, - CONFLATE - }; - - - public static final String ELEMENT_INBOUND = "throttle-inbound"; - - public static final String ELEMENT_OUTBOUND = "throttle-outbound"; - - public static final String ELEMENT_POLICY = "policy"; - - public static final String ELEMENT_DEST_FREQ = "max-frequency"; - - public static final String ELEMENT_CLIENT_FREQ = "max-client-frequency"; - - // Errors - private static final int ERR_MSG_INVALID_INBOUND_POLICY = 11130; - private static final int ERR_MSG_INVALID_INCOMING_CLENT_FREQ = 11131; - private static final int ERR_MSG_INVALID_INCOMING_DEST_FREQ = 11132; - private static final int ERR_MSG_INVALID_OUTGOING_CLIENT_FREQ = 11133; - private static final int ERR_MSG_INVALID_OUTGOING_DEST_FREQ = 11134; - private static final int ERR_MSG_INVALID_NEGATIVE_VALUE = 11135; - - private String destinationName; - private int inClientMessagesPerSec; - private int inDestinationMessagesPerSec; - private int outClientMessagesPerSec; - private int outDestinationMessagesPerSec; - private Policy inPolicy; - private Policy outPolicy; - - /** - * Creates a <code>ThrottleSettings</code> instance with default settings. - */ - public ThrottleSettings() - { - inPolicy = Policy.NONE; - outPolicy = Policy.NONE; - } - - /** - * Parses the throttle policy out of the given string. - * - * @param policy The string policy to parse. - * @return The Policy. - */ - public static Policy parsePolicy(String policy) - { - if (Policy.NONE.toString().equalsIgnoreCase(policy)) - return Policy.NONE; - else if (Policy.IGNORE.toString().equalsIgnoreCase(policy)) - return Policy.IGNORE; - else if (Policy.ERROR.toString().equalsIgnoreCase(policy)) - return Policy.ERROR; - else if (Policy.BUFFER.toString().equalsIgnoreCase(policy)) - return Policy.BUFFER; - else if (Policy.CONFLATE.toString().equalsIgnoreCase(policy)) - return Policy.CONFLATE; - - ConfigurationException ex = new ConfigurationException(); - // Message will be set by the caller. - throw ex; - } - - /** - * Returns true if inbound or outbound client throttling is enabled. - * - * @return True if the incoming client frequency or outgoing - * client frequency is enabled; otherwise false. - */ - public boolean isClientThrottleEnabled() - { - return isInboundClientThrottleEnabled() || isOutboundClientThrottleEnabled(); - } - - /** - * Returns true if inbound client throttling is enabled. - * - * @return True if the inbound client throttling is enabled. - */ - public boolean isInboundClientThrottleEnabled() - { - return inPolicy != Policy.NONE && getIncomingClientFrequency() > 0; - } - - /** - * Returns true if outbound client throttling is enabled. - * - * @return True if the outbound client throttling is enabled. - */ - public boolean isOutboundClientThrottleEnabled() - { - return outPolicy != Policy.NONE && getOutgoingClientFrequency() > 0; - } - - /** - * Returns true if inbound or outbound destination throttling is enabled. - * - * @return true if incoming or outbound destination throttling is enabled; - * otherwise false. - */ - public boolean isDestinationThrottleEnabled() - { - return isInboundDestinationThrottleEnabled() || isOutboundDestinationThrottleEnabled(); - } - - /** - * Returns true if inbound destination throttling is enabled. - * - * @return true if inbound destination throttling is enabled. - */ - public boolean isInboundDestinationThrottleEnabled() - { - return inPolicy != Policy.NONE && getIncomingDestinationFrequency() > 0; - } - - /** - * Returns true if outbound destination throttling is enabled. - * - * @return true if outbound destination throttling is enabled. - */ - public boolean isOutboundDestinationThrottleEnabled() - { - return outPolicy != Policy.NONE && getOutgoingDestinationFrequency() > 0; - } - - /** - * Returns the inbound throttle policy. - * - * @return the inbound throttle policy. - */ - public Policy getInboundPolicy() - { - return inPolicy; - } - - /** - * Sets inbound throttle policy. The inbound policy may be NONE, ERROR, or IGNORE. - * - * @param inPolicy The inbound policy. - */ - public void setInboundPolicy(Policy inPolicy) - { - if (inPolicy != Policy.NONE && inPolicy != Policy.ERROR && inPolicy != Policy.IGNORE) - { - ConfigurationException ex = new ConfigurationException(); - // Invalid inbound throttle policy ''{0}'' for destination ''{1}''. Valid values are 'NONE', 'ERROR', and 'IGNORE'. - ex.setMessage(ERR_MSG_INVALID_INBOUND_POLICY, new Object[]{inPolicy, destinationName}); - throw ex; - } - this.inPolicy = inPolicy; - } - - /** - * Returns the outbound throttle policy. - * - * @return the outbound throttle policy. - */ - public Policy getOutboundPolicy() - { - return outPolicy; - } - - /** - * Sets the outbound throttle policy. The outbound policy can be NONE, IGNORE, - * BUFFER, or CONFLATE. - * - * @param outPolicy The outbound policy. - */ - public void setOutboundPolicy(Policy outPolicy) - { - // Policy is checked at throttle manager. - this.outPolicy = outPolicy; - } - - /** - * Returns the destination name for <code>ThrottleSettings</code>. - * - * @return the destination name for <code>ThrottleSettings</code>. - */ - public String getDestinationName() - { - return destinationName; - } - - /** - * Sets the destination name for <code>ThrottleSettings</code>. This is set - * automatically when <code>NetworkSettings</code> is assigned to a destination. - * - * @param destinationName The destination name. - */ - public void setDestinationName(String destinationName) - { - this.destinationName = destinationName; - } - - /** - * Returns the incoming client frequency (max-client-frequency). - * - * @return The incoming client frequency (max-client-frequency). - */ - public int getIncomingClientFrequency() - { - return inClientMessagesPerSec; - } - - /** - * Sets the incoming client frequency (max-client-frequency). Optional and the - * default value is 0. Note that the incoming client frequency cannot be more - * than the incoming destination frequency. - * - * @param n The incoming client frequency. - */ - public void setIncomingClientFrequency(int n) - { - String name = "incoming client frequency"; - blockNegative(n, name); - - if (inDestinationMessagesPerSec > 0 && n > inDestinationMessagesPerSec) - { - ConfigurationException ex = new ConfigurationException(); - // Invalid {0} for destination ''{1}''. {0} ''{2}'' cannot be more than the incoming destination frequency ''{3}''. - ex.setMessage(ERR_MSG_INVALID_INCOMING_CLENT_FREQ, new Object[]{name, destinationName, - Integer.valueOf(n), Integer.valueOf(inDestinationMessagesPerSec)}); - throw ex; - } - this.inClientMessagesPerSec = n; - } - - /** - * Returns the incoming destination frequency (max-frequency). - * - * @return The incoming destination frequency (max-frequency). - */ - public int getIncomingDestinationFrequency() - { - return inDestinationMessagesPerSec; - } - - /** - * Sets the incoming destination frequency (max-frequency). Optional and the - * default value is 0. Note that the incoming destination frequency cannot be - * less than the incoming client frequency. - * - * @param n The incoming destination frequency. - */ - public void setIncomingDestinationFrequency(int n) - { - String name = "The incoming destination frequency"; - blockNegative(n, name); - - if (inClientMessagesPerSec > 0 && n < inClientMessagesPerSec) - { - ConfigurationException ex = new ConfigurationException(); - // Invalid {0} for destination ''{1}''. {0} ''{2}'' cannot be less than the incoming client frequency ''{3}''. - ex.setMessage(ERR_MSG_INVALID_INCOMING_DEST_FREQ, new Object[]{name, destinationName, - Integer.valueOf(n), Integer.valueOf(inClientMessagesPerSec)}); - throw ex; - } - this.inDestinationMessagesPerSec = n; - } - - /** - * Returns the outgoing client frequency (max-client-frequency). - * - * @return The outgoing client frequency (max-client-frequency). - */ - public int getOutgoingClientFrequency() - { - return outClientMessagesPerSec; - } - - /** - * Sets the outgoing client frequency (max-client-frequency). Optional and the - * default value is 0. Note that the outgoing client frequency cannot be - * more than the outgoing destination frequency. - * - * @param n The outgoing client frequency. - */ - public void setOutgoingClientFrequency(int n) - { - String name = "The outgoing client frequency"; - blockNegative(n, name); - - if (outDestinationMessagesPerSec > 0 && n > outDestinationMessagesPerSec) - { - ConfigurationException ex = new ConfigurationException(); - // Invalid {0} for destination ''{1}''. {0} ''{2}'' cannot be more than the outgoing destination frequency ''{3}''. - ex.setMessage(ERR_MSG_INVALID_OUTGOING_CLIENT_FREQ, new Object[]{name, destinationName, - Integer.valueOf(n), Integer.valueOf(outDestinationMessagesPerSec)}); - throw ex; - } - this.outClientMessagesPerSec = n; - } - - /** - * Returns the outgoing destination frequency (max-frequency). - * - * @return The outgoing destination frequency (max-frequency). - */ - public int getOutgoingDestinationFrequency() - { - return outDestinationMessagesPerSec; - } - - /** - * Sets the outgoing destination frequency (max-frequency). Optional and the - * default value is 0. Note that the outgoing destination frequency cannot - * be less than the outgoing client frequency. - * - * @param n The outgoing destination frequency. - */ - public void setOutgoingDestinationFrequency(int n) - { - String name = "The outgoing destination frequency"; - blockNegative(n, name); - - if (outClientMessagesPerSec > 0 && n < outClientMessagesPerSec) - { - ConfigurationException ex = new ConfigurationException(); - // Invalid {0} for destination ''{1}''. {0} ''{2}'' cannot be less than the outgoing client frequency ''{3}''. - ex.setMessage(ERR_MSG_INVALID_OUTGOING_DEST_FREQ, new Object[]{name, destinationName, Integer.valueOf(n), - Integer.valueOf(outClientMessagesPerSec)}); - throw ex; - } - this.outDestinationMessagesPerSec = n; - } - - protected void blockNegative(int n, String name) - { - if (n < 0) - { - ConfigurationException ex = new ConfigurationException(); - // Invalid {0} for destination ''{1}''. {0} cannot be negative. - ex.setMessage(ERR_MSG_INVALID_NEGATIVE_VALUE, new Object[]{name, destinationName}); - throw ex; - } - } -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/8315f8fa/core/src/flex/messaging/config/ValidatorSettings.java ---------------------------------------------------------------------- diff --git a/core/src/flex/messaging/config/ValidatorSettings.java b/core/src/flex/messaging/config/ValidatorSettings.java deleted file mode 100644 index ed2ab75..0000000 --- a/core/src/flex/messaging/config/ValidatorSettings.java +++ /dev/null @@ -1,68 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package flex.messaging.config; - -import flex.messaging.validators.DeserializationValidator; - -/** - * Settings class for validators. - */ -public class ValidatorSettings extends PropertiesSettings -{ - private String className; - private String type = DeserializationValidator.class.getName(); - - /** - * Returns the class name. - * - * @return The class name. - */ - public String getClassName() - { - return className; - } - - /** - * Sets the class name. - * - * @param className The class name. - */ - public void setClassName(String className) - { - this.className = className; - } - - /** - * Returns the type of the validator. - * - * @return The type of the validator. - */ - public String getType() - { - return type; - } - - /** - * Sets the type of the validator. - * - * @param type The type of the validator. - */ - public void setType(String type) - { - this.type = type; - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/8315f8fa/core/src/flex/messaging/config/XPathServerConfigurationParser.java ---------------------------------------------------------------------- diff --git a/core/src/flex/messaging/config/XPathServerConfigurationParser.java b/core/src/flex/messaging/config/XPathServerConfigurationParser.java deleted file mode 100644 index c567f21..0000000 --- a/core/src/flex/messaging/config/XPathServerConfigurationParser.java +++ /dev/null @@ -1,93 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package flex.messaging.config; - -import org.w3c.dom.Node; -import org.w3c.dom.NodeList; - -import javax.xml.xpath.XPath; -import javax.xml.xpath.XPathConstants; -import javax.xml.xpath.XPathExpressionException; -import javax.xml.xpath.XPathFactory; - -/** - * Uses Sun's JDK 1.5 XPath implementation on a DOM - * representation of a messaging configuration file. - * <p> - * Note: Since reference ids are used between elements, certain - * sections of the document need to be parsed first. - * </p> - * - * - */ -public class XPathServerConfigurationParser extends ServerConfigurationParser -{ - private XPath xpath; - - protected void initializeExpressionQuery() - { - this.xpath = XPathFactory.newInstance().newXPath(); - } - - protected Node selectSingleNode(Node source, String expression) - { - try - { - return (Node) xpath.evaluate - (expression, source, XPathConstants.NODE); - } - catch (XPathExpressionException expressionException) - { - throw wrapException(expressionException); - } - } - - protected NodeList selectNodeList(Node source, String expression) - { - try - { - return (NodeList) xpath.evaluate - (expression, source, XPathConstants.NODESET); - } - catch (XPathExpressionException expressionException) - { - throw wrapException(expressionException); - } - } - - protected Object evaluateExpression(Node source, String expression) - { - try - { - return xpath.evaluate(expression, source, XPathConstants.STRING); - } - catch (XPathExpressionException expressionException) - { - throw wrapException(expressionException); - } - } - - private ConfigurationException wrapException - (XPathExpressionException exception) - { - ConfigurationException result = new ConfigurationException(); - result.setDetails(PARSER_INTERNAL_ERROR); - result.setRootCause(exception); - return result; - } - -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/8315f8fa/core/src/flex/messaging/config/package-info.java ---------------------------------------------------------------------- diff --git a/core/src/flex/messaging/config/package-info.java b/core/src/flex/messaging/config/package-info.java deleted file mode 100644 index 266fd52..0000000 --- a/core/src/flex/messaging/config/package-info.java +++ /dev/null @@ -1,18 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package flex.messaging.config; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/8315f8fa/core/src/flex/messaging/endpoints/AMFEndpoint.java ---------------------------------------------------------------------- diff --git a/core/src/flex/messaging/endpoints/AMFEndpoint.java b/core/src/flex/messaging/endpoints/AMFEndpoint.java deleted file mode 100644 index 1f94c4b..0000000 --- a/core/src/flex/messaging/endpoints/AMFEndpoint.java +++ /dev/null @@ -1,152 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package flex.messaging.endpoints; - -import flex.management.runtime.messaging.endpoints.AMFEndpointControl; -import flex.messaging.MessageBroker; -import flex.messaging.io.MessageIOConstants; -import flex.messaging.endpoints.amf.AMFFilter; -import flex.messaging.endpoints.amf.BatchProcessFilter; -import flex.messaging.endpoints.amf.LegacyFilter; -import flex.messaging.endpoints.amf.MessageBrokerFilter; -import flex.messaging.endpoints.amf.SerializationFilter; -import flex.messaging.endpoints.amf.SessionFilter; -import flex.messaging.log.LogCategories; - -/** - * AMF based endpoint for Flex Messaging. Based on the Flash Remoting gateway servlet. - */ -public class AMFEndpoint extends BasePollingHTTPEndpoint -{ - /** - * The log category for this endpoint. - */ - public static final String LOG_CATEGORY = LogCategories.ENDPOINT_AMF; - - //-------------------------------------------------------------------------- - // - // Constructors - // - //-------------------------------------------------------------------------- - - /** - * Constructs an unmanaged <code>AMFEndpoint</code>. - */ - public AMFEndpoint() - { - this(false); - } - - /** - * Constructs an <code>AMFEndpoint</code> with the indicated management. - * - * @param enableManagement <code>true</code> if the <code>AMFEndpoint</code> - * is manageable; <code>false</code> otherwise. - */ - public AMFEndpoint(boolean enableManagement) - { - super(enableManagement); - } - - //-------------------------------------------------------------------------- - // - // Protected/Private Methods - // - //-------------------------------------------------------------------------- - - /** - * Create the gateway filters that transform action requests - * and responses. - */ - @Override protected AMFFilter createFilterChain() - { - AMFFilter serializationFilter = new SerializationFilter(getLogCategory()); - AMFFilter batchFilter = new BatchProcessFilter(); - AMFFilter sessionFilter = sessionRewritingEnabled? new SessionFilter() : null; - AMFFilter envelopeFilter = new LegacyFilter(this); - AMFFilter messageBrokerFilter = new MessageBrokerFilter(this); - - serializationFilter.setNext(batchFilter); - if (sessionFilter != null) - { - batchFilter.setNext(sessionFilter); - sessionFilter.setNext(envelopeFilter); - } - else - { - batchFilter.setNext(envelopeFilter); - } - envelopeFilter.setNext(messageBrokerFilter); - - return serializationFilter; - } - - /** - * Returns MessageIOConstants.AMF_CONTENT_TYPE. - * - * @return MessageIOConstants.AMF_CONTENT_TYPE - */ - @Override protected String getResponseContentType() - { - return MessageIOConstants.AMF_CONTENT_TYPE; - } - - /** - * Returns the log category of the endpoint. - * - * @return The log category of the endpoint. - */ - @Override protected String getLogCategory() - { - return LOG_CATEGORY; - } - - /** - * Returns the deserializer class name used by the endpoint. - * - * @return The deserializer class name used by the endpoint. - */ - @Override protected String getDeserializerClassName() - { - return "flex.messaging.io.amf.AmfMessageDeserializer"; - } - - /** - * Returns the serializer class name used by the endpoint. - * - * @return The serializer class name used by the endpoint. - */ - @Override protected String getSerializerClassName() - { - return "flex.messaging.io.amf.AmfMessageSerializer"; - } - - - /** - * Invoked automatically to allow the <code>AMFEndpoint</code> to setup its - * corresponding MBean control. - * - * @param broker The <code>MessageBroker</code> that manages this - * <code>AMFEndpoint</code>. - */ - @Override protected void setupEndpointControl(MessageBroker broker) - { - controller = new AMFEndpointControl(this, broker.getControl()); - controller.register(); - setControl(controller); - } -}
