You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by as...@apache.org on 2007/03/17 17:18:47 UTC
svn commit: r519363 [8/16] - in /webservices/synapse/trunk/java:
modules/core/ modules/core/src/main/java/org/apache/synapse/
modules/core/src/main/java/org/apache/synapse/config/
modules/core/src/main/java/org/apache/synapse/config/xml/ modules/core/s...
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsHolder.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsHolder.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsHolder.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsHolder.java Sat Mar 17 09:18:32 2007
@@ -1,117 +1,117 @@
-/*
- * 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 org.apache.synapse.statistics;
-
-import org.apache.synapse.Constants;
-
-/**
- * To hold statistics that will collected during both of in and out message mediation
- */
-
-public class StatisticsHolder {
-
- private int statisticsCategory ;
-
- private String key ;
-
- /** The statistics that will collect during in coming message mediation */
- private Statistics inFlowStatistics;
-
- /** The statistics that will collect during out going message mediation */
- private Statistics outFlowStatistics;
-
- /**
- * To update the statistics
- *
- * @param isResponse - A boolean value that indicate whether message flow is in or out
- * @param inTime - The processing start time
- * @param outTime - The processing end time
- * @param isFault - A boolean value that indicate whether falut has occured or not
- */
- public synchronized void update(boolean isResponse, long inTime, long outTime, boolean isFault) {
- if (isResponse) {
- if (outFlowStatistics == null) {
- outFlowStatistics = new Statistics();
- }
- outFlowStatistics.update(inTime, outTime, isFault);
- } else {
- if (inFlowStatistics == null) {
- inFlowStatistics = new Statistics();
- }
- inFlowStatistics.update(inTime, outTime, isFault);
- }
-
- }
-
- /**
- * To get Statistics related to the In Flow
- * @return Statistics related to the In Flow
- */
- public synchronized Statistics getInFlowStatistics() {
- return inFlowStatistics;
- }
-
- /**
- * To get Statistics related to the Out Flow
- * @return Statistics related to the Out Flow
- */
- public synchronized Statistics getOutFlowStatistics() {
- return outFlowStatistics;
- }
-
- /**
- * To get statistics category
- * @return Statistics Category
- */
- public int getStatisticsCategory() {
- return statisticsCategory;
- }
-
- /**
- * To set statistics category
- * @param statisticsCategory
- */
- public void setStatisticsCategory(int statisticsCategory) {
- this.statisticsCategory = statisticsCategory;
- }
-
- /**
- * To get key of statistics
- * @return key of statistics
- */
- public String getKey() {
- return key;
- }
-
- /**
- * To set key of statistics
- * @param key
- */
- public void setKey(String key) {
- this.key = key;
- }
-
- /**
- * To clear stored statistics
- */
- public synchronized void clearStatistics(){
- this.inFlowStatistics =null;
- this.outFlowStatistics=null;
- }
-}
+/*
+ * 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 org.apache.synapse.statistics;
+
+import org.apache.synapse.Constants;
+
+/**
+ * To hold statistics that will collected during both of in and out message mediation
+ */
+
+public class StatisticsHolder {
+
+ private int statisticsCategory ;
+
+ private String key ;
+
+ /** The statistics that will collect during in coming message mediation */
+ private Statistics inFlowStatistics;
+
+ /** The statistics that will collect during out going message mediation */
+ private Statistics outFlowStatistics;
+
+ /**
+ * To update the statistics
+ *
+ * @param isResponse - A boolean value that indicate whether message flow is in or out
+ * @param inTime - The processing start time
+ * @param outTime - The processing end time
+ * @param isFault - A boolean value that indicate whether falut has occured or not
+ */
+ public synchronized void update(boolean isResponse, long inTime, long outTime, boolean isFault) {
+ if (isResponse) {
+ if (outFlowStatistics == null) {
+ outFlowStatistics = new Statistics();
+ }
+ outFlowStatistics.update(inTime, outTime, isFault);
+ } else {
+ if (inFlowStatistics == null) {
+ inFlowStatistics = new Statistics();
+ }
+ inFlowStatistics.update(inTime, outTime, isFault);
+ }
+
+ }
+
+ /**
+ * To get Statistics related to the In Flow
+ * @return Statistics related to the In Flow
+ */
+ public synchronized Statistics getInFlowStatistics() {
+ return inFlowStatistics;
+ }
+
+ /**
+ * To get Statistics related to the Out Flow
+ * @return Statistics related to the Out Flow
+ */
+ public synchronized Statistics getOutFlowStatistics() {
+ return outFlowStatistics;
+ }
+
+ /**
+ * To get statistics category
+ * @return Statistics Category
+ */
+ public int getStatisticsCategory() {
+ return statisticsCategory;
+ }
+
+ /**
+ * To set statistics category
+ * @param statisticsCategory
+ */
+ public void setStatisticsCategory(int statisticsCategory) {
+ this.statisticsCategory = statisticsCategory;
+ }
+
+ /**
+ * To get key of statistics
+ * @return key of statistics
+ */
+ public String getKey() {
+ return key;
+ }
+
+ /**
+ * To set key of statistics
+ * @param key
+ */
+ public void setKey(String key) {
+ this.key = key;
+ }
+
+ /**
+ * To clear stored statistics
+ */
+ public synchronized void clearStatistics(){
+ this.inFlowStatistics =null;
+ this.outFlowStatistics=null;
+ }
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsHolder.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsStack.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsStack.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsStack.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsStack.java Sat Mar 17 09:18:32 2007
@@ -1,53 +1,53 @@
-/*
- * 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 org.apache.synapse.statistics;
-
-/**
- * This interface need to be implemented by each of the entry that
- * need to collect statistics
- *
- */
-
-public interface StatisticsStack {
-
- /**
- * This method is used to put current statistics
- * @param key
- * @param initTime
- * @param isInFlow
- * @param isStatisticsEnable
- * @param isFault
- */
- public void put(String key,long initTime, boolean isInFlow, boolean isStatisticsEnable,boolean isFault);
-
- /**
- * This method used to report the latest statistics to the StatisticsCollector
- * @param statisticsCollector
- * @param isFault
- */
- public void reportToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault);
-
- /**
- * This method used to unreported all statistics to the StatisticsCollector
- * @param statisticsCollector
- * @param isFault
- */
- public void reportAllToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault);
-
-}
+/*
+ * 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 org.apache.synapse.statistics;
+
+/**
+ * This interface need to be implemented by each of the entry that
+ * need to collect statistics
+ *
+ */
+
+public interface StatisticsStack {
+
+ /**
+ * This method is used to put current statistics
+ * @param key
+ * @param initTime
+ * @param isInFlow
+ * @param isStatisticsEnable
+ * @param isFault
+ */
+ public void put(String key,long initTime, boolean isInFlow, boolean isStatisticsEnable,boolean isFault);
+
+ /**
+ * This method used to report the latest statistics to the StatisticsCollector
+ * @param statisticsCollector
+ * @param isFault
+ */
+ public void reportToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault);
+
+ /**
+ * This method used to unreported all statistics to the StatisticsCollector
+ * @param statisticsCollector
+ * @param isFault
+ */
+ public void reportAllToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault);
+
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsStack.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsUtils.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsUtils.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsUtils.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsUtils.java Sat Mar 17 09:18:32 2007
@@ -1,113 +1,113 @@
-/*
- * 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 org.apache.synapse.statistics;
-
-import org.apache.synapse.Constants;
-import org.apache.synapse.MessageContext;
-import org.apache.synapse.core.SynapseEnvironment;
-import org.apache.synapse.statistics.impl.SequenceStatisticsStack;
-import org.apache.synapse.statistics.impl.EndPointStatisticsStack;
-import org.apache.synapse.statistics.impl.ProxyServiceStatisticsStack;
-
-/**
- * A utils to process statistics
- *
- */
-
-public class StatisticsUtils {
-
- /**
- * To process statistics related to the proxy services
- *
- * @param synCtx
- */
- public static void processProxyServiceStatistics(MessageContext synCtx) {
-
- StatisticsCollector statisticsCollector = getStatisticsCollector(synCtx);
- boolean isFault = synCtx.getEnvelope().getBody().hasFault();
- ProxyServiceStatisticsStack proxyServiceStatisticsStack = (ProxyServiceStatisticsStack) synCtx.getProperty(Constants.PROXYSERVICE_STATISTICS_STACK);
- if (proxyServiceStatisticsStack != null) {
- proxyServiceStatisticsStack.reportToStatisticsCollector(statisticsCollector,isFault);
- }
- ProxyServiceStatisticsStack synapseServiceStatisticsStack = (ProxyServiceStatisticsStack) synCtx.getProperty(Constants.SYNAPSESERVICE_STATISTICS_STACK);
- if (synapseServiceStatisticsStack != null) {
- synapseServiceStatisticsStack.reportToStatisticsCollector(statisticsCollector,isFault);
- }
- }
-
- /**
- * To process statistics related to the End Points
- *
- * @param synCtx
- */
- public static void processEndPointStatistics(MessageContext synCtx) {
- StatisticsCollector statisticsCollector = getStatisticsCollector(synCtx);
- boolean isFault = synCtx.getEnvelope().getBody().hasFault();
- EndPointStatisticsStack endPointStatisticsStack = (EndPointStatisticsStack) synCtx.getProperty(Constants.ENDPOINT_STATISTICS_STACK);
- if (endPointStatisticsStack != null) {
- endPointStatisticsStack.reportToStatisticsCollector(statisticsCollector,isFault);
- }
- }
-
- /**
- * To process statistics related to the sequence
- *
- * @param synCtx
- */
- public static void processSequenceStatistics(MessageContext synCtx) {
- StatisticsCollector statisticsCollector = getStatisticsCollector(synCtx);
- boolean isFault = synCtx.getEnvelope().getBody().hasFault();
- SequenceStatisticsStack sequenceStatisticsStack = (SequenceStatisticsStack) synCtx.getProperty(Constants.SEQUENCE_STATISTICS_STACK);
- if (sequenceStatisticsStack != null) {
- sequenceStatisticsStack.reportToStatisticsCollector(statisticsCollector,isFault);
- }
- }
-
- /**
- * To process all statistics related to the sequence
- *
- * @param synCtx
- */
- public static void processAllSequenceStatistics(MessageContext synCtx) {
- StatisticsCollector statisticsCollector = getStatisticsCollector(synCtx);
- boolean isFault = synCtx.getEnvelope().getBody().hasFault();
- SequenceStatisticsStack sequenceStatisticsStack = (SequenceStatisticsStack) synCtx.getProperty(Constants.SEQUENCE_STATISTICS_STACK);
- if (sequenceStatisticsStack != null) {
- sequenceStatisticsStack.reportAllToStatisticsCollector(statisticsCollector,isFault);
- }
- }
- /**
- * A helper method to get StatisticsCollector from the Synapse Message Context
- *
- * @param synCtx
- * @return StatisticsCollector
- */
- private static StatisticsCollector getStatisticsCollector(MessageContext synCtx) {
- SynapseEnvironment synEnv = synCtx.getEnvironment();
- StatisticsCollector statisticsCollector = null;
- if (synEnv != null) {
- statisticsCollector = synEnv.getStatisticsCollector();
- if (statisticsCollector == null) {
- statisticsCollector = new StatisticsCollector();
- synEnv.setStatisticsCollector(statisticsCollector);
- }
- }
- return statisticsCollector;
- }
-}
+/*
+ * 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 org.apache.synapse.statistics;
+
+import org.apache.synapse.Constants;
+import org.apache.synapse.MessageContext;
+import org.apache.synapse.core.SynapseEnvironment;
+import org.apache.synapse.statistics.impl.SequenceStatisticsStack;
+import org.apache.synapse.statistics.impl.EndPointStatisticsStack;
+import org.apache.synapse.statistics.impl.ProxyServiceStatisticsStack;
+
+/**
+ * A utils to process statistics
+ *
+ */
+
+public class StatisticsUtils {
+
+ /**
+ * To process statistics related to the proxy services
+ *
+ * @param synCtx
+ */
+ public static void processProxyServiceStatistics(MessageContext synCtx) {
+
+ StatisticsCollector statisticsCollector = getStatisticsCollector(synCtx);
+ boolean isFault = synCtx.getEnvelope().getBody().hasFault();
+ ProxyServiceStatisticsStack proxyServiceStatisticsStack = (ProxyServiceStatisticsStack) synCtx.getProperty(Constants.PROXYSERVICE_STATISTICS_STACK);
+ if (proxyServiceStatisticsStack != null) {
+ proxyServiceStatisticsStack.reportToStatisticsCollector(statisticsCollector,isFault);
+ }
+ ProxyServiceStatisticsStack synapseServiceStatisticsStack = (ProxyServiceStatisticsStack) synCtx.getProperty(Constants.SYNAPSESERVICE_STATISTICS_STACK);
+ if (synapseServiceStatisticsStack != null) {
+ synapseServiceStatisticsStack.reportToStatisticsCollector(statisticsCollector,isFault);
+ }
+ }
+
+ /**
+ * To process statistics related to the End Points
+ *
+ * @param synCtx
+ */
+ public static void processEndPointStatistics(MessageContext synCtx) {
+ StatisticsCollector statisticsCollector = getStatisticsCollector(synCtx);
+ boolean isFault = synCtx.getEnvelope().getBody().hasFault();
+ EndPointStatisticsStack endPointStatisticsStack = (EndPointStatisticsStack) synCtx.getProperty(Constants.ENDPOINT_STATISTICS_STACK);
+ if (endPointStatisticsStack != null) {
+ endPointStatisticsStack.reportToStatisticsCollector(statisticsCollector,isFault);
+ }
+ }
+
+ /**
+ * To process statistics related to the sequence
+ *
+ * @param synCtx
+ */
+ public static void processSequenceStatistics(MessageContext synCtx) {
+ StatisticsCollector statisticsCollector = getStatisticsCollector(synCtx);
+ boolean isFault = synCtx.getEnvelope().getBody().hasFault();
+ SequenceStatisticsStack sequenceStatisticsStack = (SequenceStatisticsStack) synCtx.getProperty(Constants.SEQUENCE_STATISTICS_STACK);
+ if (sequenceStatisticsStack != null) {
+ sequenceStatisticsStack.reportToStatisticsCollector(statisticsCollector,isFault);
+ }
+ }
+
+ /**
+ * To process all statistics related to the sequence
+ *
+ * @param synCtx
+ */
+ public static void processAllSequenceStatistics(MessageContext synCtx) {
+ StatisticsCollector statisticsCollector = getStatisticsCollector(synCtx);
+ boolean isFault = synCtx.getEnvelope().getBody().hasFault();
+ SequenceStatisticsStack sequenceStatisticsStack = (SequenceStatisticsStack) synCtx.getProperty(Constants.SEQUENCE_STATISTICS_STACK);
+ if (sequenceStatisticsStack != null) {
+ sequenceStatisticsStack.reportAllToStatisticsCollector(statisticsCollector,isFault);
+ }
+ }
+ /**
+ * A helper method to get StatisticsCollector from the Synapse Message Context
+ *
+ * @param synCtx
+ * @return StatisticsCollector
+ */
+ private static StatisticsCollector getStatisticsCollector(MessageContext synCtx) {
+ SynapseEnvironment synEnv = synCtx.getEnvironment();
+ StatisticsCollector statisticsCollector = null;
+ if (synEnv != null) {
+ statisticsCollector = synEnv.getStatisticsCollector();
+ if (statisticsCollector == null) {
+ statisticsCollector = new StatisticsCollector();
+ synEnv.setStatisticsCollector(statisticsCollector);
+ }
+ }
+ return statisticsCollector;
+ }
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/StatisticsUtils.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/EndPointStatisticsStack.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/EndPointStatisticsStack.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/EndPointStatisticsStack.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/EndPointStatisticsStack.java Sat Mar 17 09:18:32 2007
@@ -1,76 +1,76 @@
-/*
- * 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 org.apache.synapse.statistics.impl;
-
-import org.apache.synapse.statistics.StatisticsStack;
-import org.apache.synapse.statistics.StatisticsCollector;
-
-/**
- * The data structure to hold statistics related to the end points
- *
- */
-
-public class EndPointStatisticsStack implements StatisticsStack {
-
- /** The name of the endpoint */
- private String endPointName;
- /** The time which starts to collect statistics */
- private long initTime;
- /** To check whether IN message flow or not */
- private boolean isInFlow;
- /** To check whether statistics is enabled or not */
- private boolean isStatisticsEnable;
- /** To indicate whether this is fault or not*/
- private boolean isFault;
- /**
- * To put statistics
- * @param key - The name of the End Point
- * @param initTime
- * @param isInFlow
- * @param isStatisticsEnable
- * @param isFault
- */
- public void put(String key, long initTime, boolean isInFlow, boolean isStatisticsEnable,boolean isFault) {
- this.endPointName = key;
- this.initTime = initTime;
- this.isInFlow = isInFlow;
- this.isStatisticsEnable = isStatisticsEnable;
- this.isFault = isFault;
- }
-
- /**
- * This method used to report the latest statistics to the StatisticsCollector
- * @param statisticsCollector
- * @param isFault
- */
- public void reportToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
- if (isStatisticsEnable && endPointName!=null) {
- statisticsCollector.reportForEndPoint(endPointName, !isInFlow, initTime, System.currentTimeMillis(), isFault);
- endPointName =null;
- }
- }
-
- /**
- * This method used to unreported all statistics to the StatisticsCollector
- * @param statisticsCollector
- */
- public void reportAllToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
- reportToStatisticsCollector(statisticsCollector,isFault);
- }
-}
+/*
+ * 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 org.apache.synapse.statistics.impl;
+
+import org.apache.synapse.statistics.StatisticsStack;
+import org.apache.synapse.statistics.StatisticsCollector;
+
+/**
+ * The data structure to hold statistics related to the end points
+ *
+ */
+
+public class EndPointStatisticsStack implements StatisticsStack {
+
+ /** The name of the endpoint */
+ private String endPointName;
+ /** The time which starts to collect statistics */
+ private long initTime;
+ /** To check whether IN message flow or not */
+ private boolean isInFlow;
+ /** To check whether statistics is enabled or not */
+ private boolean isStatisticsEnable;
+ /** To indicate whether this is fault or not*/
+ private boolean isFault;
+ /**
+ * To put statistics
+ * @param key - The name of the End Point
+ * @param initTime
+ * @param isInFlow
+ * @param isStatisticsEnable
+ * @param isFault
+ */
+ public void put(String key, long initTime, boolean isInFlow, boolean isStatisticsEnable,boolean isFault) {
+ this.endPointName = key;
+ this.initTime = initTime;
+ this.isInFlow = isInFlow;
+ this.isStatisticsEnable = isStatisticsEnable;
+ this.isFault = isFault;
+ }
+
+ /**
+ * This method used to report the latest statistics to the StatisticsCollector
+ * @param statisticsCollector
+ * @param isFault
+ */
+ public void reportToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
+ if (isStatisticsEnable && endPointName!=null) {
+ statisticsCollector.reportForEndPoint(endPointName, !isInFlow, initTime, System.currentTimeMillis(), isFault);
+ endPointName =null;
+ }
+ }
+
+ /**
+ * This method used to unreported all statistics to the StatisticsCollector
+ * @param statisticsCollector
+ */
+ public void reportAllToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
+ reportToStatisticsCollector(statisticsCollector,isFault);
+ }
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/EndPointStatisticsStack.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/ProxyServiceStatisticsStack.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/ProxyServiceStatisticsStack.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/ProxyServiceStatisticsStack.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/ProxyServiceStatisticsStack.java Sat Mar 17 09:18:32 2007
@@ -1,85 +1,85 @@
-/*
- * 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 org.apache.synapse.statistics.impl;
-
-import org.apache.synapse.statistics.StatisticsStack;
-import org.apache.synapse.statistics.StatisticsCollector;
-
-/**
- * The data structure to hold statistics related to the Proxy Services
- *
- */
-
-public class ProxyServiceStatisticsStack implements StatisticsStack {
-
- /** The name of the proxy service*/
- private String proxyServiceName;
- /** To check whether statistics is enabled or not */
- private boolean isStatisticsEnable = false;
- /** The time which starts to collect statistics for IN flow */
- private long inTimeForInFlow = -1;
- /** The time which starts to collect statistics for OUT flow */
- private long inTimeForOutFlow = -1;
- /** To indicate whether IN Flow is fault or not*/
- private boolean isINFault;
- /** To indicate whether OUT Flow is fault or not*/
- private boolean isOUTFault;
- /**
- * To put a statistics
- * @param key - The Name of the proxy service
- * @param initTime
- * @param isInFlow
- * @param isStatisticsEnable
- */
- public void put(String key, long initTime, boolean isInFlow, boolean isStatisticsEnable,boolean isFault) {
-
- if (isInFlow) {
- this.proxyServiceName = key;
- this.isStatisticsEnable = isStatisticsEnable;
- this.inTimeForInFlow = initTime;
- this.isINFault = isFault;
- }
- }
-
- /**
- * This method used to report the latest statistics to the StatisticsCollector
- * @param statisticsCollector
- */
- public void reportToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
-
- if (proxyServiceName != null && isStatisticsEnable && inTimeForInFlow != -1) {
- inTimeForOutFlow = System.currentTimeMillis();
- isOUTFault = isFault;
- statisticsCollector.reportForProxyService(proxyServiceName, false, inTimeForInFlow, inTimeForOutFlow, isINFault);
- inTimeForInFlow = -1;
- } else if (inTimeForOutFlow != -1) {
- statisticsCollector.reportForProxyService(proxyServiceName, true, inTimeForOutFlow, System.currentTimeMillis(), isFault);
- inTimeForOutFlow = -1;
- }
- }
-
- /**
- * This method used to unreported all statistics to the StatisticsCollector
- * @param statisticsCollector
- * @param isFault
- */
- public void reportAllToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
- reportToStatisticsCollector(statisticsCollector,isFault);
- }
-}
+/*
+ * 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 org.apache.synapse.statistics.impl;
+
+import org.apache.synapse.statistics.StatisticsStack;
+import org.apache.synapse.statistics.StatisticsCollector;
+
+/**
+ * The data structure to hold statistics related to the Proxy Services
+ *
+ */
+
+public class ProxyServiceStatisticsStack implements StatisticsStack {
+
+ /** The name of the proxy service*/
+ private String proxyServiceName;
+ /** To check whether statistics is enabled or not */
+ private boolean isStatisticsEnable = false;
+ /** The time which starts to collect statistics for IN flow */
+ private long inTimeForInFlow = -1;
+ /** The time which starts to collect statistics for OUT flow */
+ private long inTimeForOutFlow = -1;
+ /** To indicate whether IN Flow is fault or not*/
+ private boolean isINFault;
+ /** To indicate whether OUT Flow is fault or not*/
+ private boolean isOUTFault;
+ /**
+ * To put a statistics
+ * @param key - The Name of the proxy service
+ * @param initTime
+ * @param isInFlow
+ * @param isStatisticsEnable
+ */
+ public void put(String key, long initTime, boolean isInFlow, boolean isStatisticsEnable,boolean isFault) {
+
+ if (isInFlow) {
+ this.proxyServiceName = key;
+ this.isStatisticsEnable = isStatisticsEnable;
+ this.inTimeForInFlow = initTime;
+ this.isINFault = isFault;
+ }
+ }
+
+ /**
+ * This method used to report the latest statistics to the StatisticsCollector
+ * @param statisticsCollector
+ */
+ public void reportToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
+
+ if (proxyServiceName != null && isStatisticsEnable && inTimeForInFlow != -1) {
+ inTimeForOutFlow = System.currentTimeMillis();
+ isOUTFault = isFault;
+ statisticsCollector.reportForProxyService(proxyServiceName, false, inTimeForInFlow, inTimeForOutFlow, isINFault);
+ inTimeForInFlow = -1;
+ } else if (inTimeForOutFlow != -1) {
+ statisticsCollector.reportForProxyService(proxyServiceName, true, inTimeForOutFlow, System.currentTimeMillis(), isFault);
+ inTimeForOutFlow = -1;
+ }
+ }
+
+ /**
+ * This method used to unreported all statistics to the StatisticsCollector
+ * @param statisticsCollector
+ * @param isFault
+ */
+ public void reportAllToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
+ reportToStatisticsCollector(statisticsCollector,isFault);
+ }
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/ProxyServiceStatisticsStack.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/SequenceStatisticsStack.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/SequenceStatisticsStack.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/SequenceStatisticsStack.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/SequenceStatisticsStack.java Sat Mar 17 09:18:32 2007
@@ -1,113 +1,113 @@
-/*
- * 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 org.apache.synapse.statistics.impl;
-
-import org.apache.synapse.statistics.StatisticsStack;
-import org.apache.synapse.statistics.StatisticsCollector;
-
-import java.util.ArrayList;
-
-/**
- * The data structure to hold statistics related to Sequences
- *
- */
-
-public class SequenceStatisticsStack implements StatisticsStack {
-
- /** The list to hols SequenceStatistics */
- private ArrayList sequenceStatisticsList = new ArrayList();
-
- /**
- * To put a statistics
- * @param sequenceName - The name of the sequence
- * @param initTime
- * @param isInFlow
- * @param isStatisticsEnable
- * @param isFault
- */
- public void put(String sequenceName, long initTime, boolean isInFlow, boolean isStatisticsEnable,boolean isFault) {
- sequenceStatisticsList.add(new SequenceStatistics(sequenceName, initTime, isInFlow, isStatisticsEnable,isFault));
- }
- /**
- * This method used to report the latest statistics to the StatisticsCollector
- * @param statisticsCollector
- * @param isFault
- */
- public void reportToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
- int top = sequenceStatisticsList.size();
- if (top > 0) {
- popSequenceStatistics(sequenceStatisticsList.size() - 1, statisticsCollector);
- }
- }
- /**
- * This method used to unreported all statistics to the StatisticsCollector
- * @param statisticsCollector
- * @param isFault
- */
- public void reportAllToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
- int i = sequenceStatisticsList.size()-1;
- for (; i >=0; i--) {
- popSequenceStatistics(i, statisticsCollector);
- }
- }
-
- /**
- * A helper method to pop a SequenceStatistics
- * @param index
- * @param statisticsCollector
- */
- private void popSequenceStatistics(int index, StatisticsCollector statisticsCollector) {
- if (index >= 0) {
- SequenceStatistics sequenceStatistics = (SequenceStatistics) sequenceStatisticsList.get(index);
- if (sequenceStatistics != null) {
- if (sequenceStatistics.isStatisticsEnable && sequenceStatistics.sequenceName != null)
- {
- statisticsCollector.reportForSequence(sequenceStatistics.sequenceName, !sequenceStatistics.isInFlow, sequenceStatistics.initTime, System.currentTimeMillis(), sequenceStatistics.isFault);
- }
- sequenceStatisticsList.remove(index);
- }
- }
- }
-
- /**
- * The SequenceStatistics data structure
- */
- class SequenceStatistics {
-
- /** The name of the Sequence */
- String sequenceName;
- /** The time which starts to collect statistics */
- long initTime;
- /** To check whether IN message flow or not */
- boolean isInFlow;
- /** To check whether statistics is enabled or not */
- boolean isStatisticsEnable;
- /** To indicate whether this is fault or not*/
- private boolean isFault;
-
- public SequenceStatistics(String sequenceName, long initTime, boolean inFlow, boolean statisticsEnable,boolean isFault) {
- this.sequenceName = sequenceName;
- this.initTime = initTime;
- isInFlow = inFlow;
- isStatisticsEnable = statisticsEnable;
- this.isFault = isFault;
- }
- }
-
-}
+/*
+ * 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 org.apache.synapse.statistics.impl;
+
+import org.apache.synapse.statistics.StatisticsStack;
+import org.apache.synapse.statistics.StatisticsCollector;
+
+import java.util.ArrayList;
+
+/**
+ * The data structure to hold statistics related to Sequences
+ *
+ */
+
+public class SequenceStatisticsStack implements StatisticsStack {
+
+ /** The list to hols SequenceStatistics */
+ private ArrayList sequenceStatisticsList = new ArrayList();
+
+ /**
+ * To put a statistics
+ * @param sequenceName - The name of the sequence
+ * @param initTime
+ * @param isInFlow
+ * @param isStatisticsEnable
+ * @param isFault
+ */
+ public void put(String sequenceName, long initTime, boolean isInFlow, boolean isStatisticsEnable,boolean isFault) {
+ sequenceStatisticsList.add(new SequenceStatistics(sequenceName, initTime, isInFlow, isStatisticsEnable,isFault));
+ }
+ /**
+ * This method used to report the latest statistics to the StatisticsCollector
+ * @param statisticsCollector
+ * @param isFault
+ */
+ public void reportToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
+ int top = sequenceStatisticsList.size();
+ if (top > 0) {
+ popSequenceStatistics(sequenceStatisticsList.size() - 1, statisticsCollector);
+ }
+ }
+ /**
+ * This method used to unreported all statistics to the StatisticsCollector
+ * @param statisticsCollector
+ * @param isFault
+ */
+ public void reportAllToStatisticsCollector(StatisticsCollector statisticsCollector,boolean isFault) {
+ int i = sequenceStatisticsList.size()-1;
+ for (; i >=0; i--) {
+ popSequenceStatistics(i, statisticsCollector);
+ }
+ }
+
+ /**
+ * A helper method to pop a SequenceStatistics
+ * @param index
+ * @param statisticsCollector
+ */
+ private void popSequenceStatistics(int index, StatisticsCollector statisticsCollector) {
+ if (index >= 0) {
+ SequenceStatistics sequenceStatistics = (SequenceStatistics) sequenceStatisticsList.get(index);
+ if (sequenceStatistics != null) {
+ if (sequenceStatistics.isStatisticsEnable && sequenceStatistics.sequenceName != null)
+ {
+ statisticsCollector.reportForSequence(sequenceStatistics.sequenceName, !sequenceStatistics.isInFlow, sequenceStatistics.initTime, System.currentTimeMillis(), sequenceStatistics.isFault);
+ }
+ sequenceStatisticsList.remove(index);
+ }
+ }
+ }
+
+ /**
+ * The SequenceStatistics data structure
+ */
+ class SequenceStatistics {
+
+ /** The name of the Sequence */
+ String sequenceName;
+ /** The time which starts to collect statistics */
+ long initTime;
+ /** To check whether IN message flow or not */
+ boolean isInFlow;
+ /** To check whether statistics is enabled or not */
+ boolean isStatisticsEnable;
+ /** To indicate whether this is fault or not*/
+ private boolean isFault;
+
+ public SequenceStatistics(String sequenceName, long initTime, boolean inFlow, boolean statisticsEnable,boolean isFault) {
+ this.sequenceName = sequenceName;
+ this.initTime = initTime;
+ isInFlow = inFlow;
+ isStatisticsEnable = statisticsEnable;
+ this.isFault = isFault;
+ }
+ }
+
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/statistics/impl/SequenceStatisticsStack.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: webservices/synapse/trunk/java/modules/core/src/main/resources/log4j.properties
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/TestMessageContext.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/AbstractTestCase.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/AbstractTestCase.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/AbstractTestCase.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/AbstractTestCase.java Sat Mar 17 09:18:32 2007
@@ -1,125 +1,125 @@
-/*
- * 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 org.apache.synapse.config.xml;
-
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.impl.builder.StAXOMBuilder;
-import org.apache.synapse.Mediator;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.custommonkey.xmlunit.XMLTestCase;
-import org.xml.sax.SAXException;
-
-import javax.xml.stream.XMLInputFactory;
-import javax.xml.stream.XMLStreamException;
-import javax.xml.stream.XMLStreamReader;
-import javax.xml.parsers.ParserConfigurationException;
-import java.io.StringReader;
-import java.io.IOException;
-
-/**
- *
- *
- */
-
-public abstract class AbstractTestCase extends XMLTestCase {
-
- private static final Log log = LogFactory.getLog(AbstractTestCase.class);
-
- public AbstractTestCase(String name) {
- super(name);
- }
-
- public AbstractTestCase() {
- }
-
- protected void setUp() throws Exception {
- super.setUp();
- }
-
- protected OMElement createOMElement(String xml) {
- try {
-
- XMLStreamReader reader = XMLInputFactory.newInstance().createXMLStreamReader(new StringReader(xml));
- StAXOMBuilder builder = new StAXOMBuilder(reader);
- OMElement omElement = builder.getDocumentElement();
- return omElement;
-
- }
- catch (XMLStreamException e) {
- throw new RuntimeException(e);
- }
- }
-
- protected boolean serialization(String inputXml, MediatorFactory mediatorFactory, MediatorSerializer mediatorSerializer) {
-
- OMElement inputOM = createOMElement(inputXml);
- Mediator mediator = mediatorFactory.createMediator(inputOM);
- OMElement resultOM = mediatorSerializer.serializeMediator(null, mediator);
- try {
- assertXMLEqual(resultOM.toString(), inputXml);
- return true;
- } catch (SAXException e) {
- log.error(e);
- } catch (IOException e) {
- log.error(e);
- } catch (ParserConfigurationException e) {
- log.error(e);
- }
- return false;
- }
-
- protected boolean serialization(String inputXml, MediatorSerializer mediatorSerializer) {
- OMElement inputOM = createOMElement(inputXml);
- Mediator mediator = MediatorFactoryFinder.getInstance().getMediator(inputOM);
- OMElement resultOM = mediatorSerializer.serializeMediator(null, mediator);
- try {
- assertXMLEqual(resultOM.toString(), inputXml);
- return true;
- } catch (SAXException e) {
- log.error(e);
- } catch (IOException e) {
- log.error(e);
- } catch (ParserConfigurationException e) {
- log.error(e);
- }
- return false;
- }
-
- protected OMElement getParent() {
- String parentXML = "<synapse xmlns=\"http://ws.apache.org/ns/synapse\"><definitions></definitions></synapse>";
- return createOMElement(parentXML);
- }
-
- protected boolean compare(OMElement inputElement, OMElement serializedElement) {
- try {
-
- assertXMLEqual(inputElement.toString(), serializedElement.toString());
- return true;
- } catch (SAXException e) {
- log.error(e);
- } catch (IOException e) {
- log.error(e);
- } catch (ParserConfigurationException e) {
- log.error(e);
- }
- return false;
- }
-}
+/*
+ * 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 org.apache.synapse.config.xml;
+
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.impl.builder.StAXOMBuilder;
+import org.apache.synapse.Mediator;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.custommonkey.xmlunit.XMLTestCase;
+import org.xml.sax.SAXException;
+
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.parsers.ParserConfigurationException;
+import java.io.StringReader;
+import java.io.IOException;
+
+/**
+ *
+ *
+ */
+
+public abstract class AbstractTestCase extends XMLTestCase {
+
+ private static final Log log = LogFactory.getLog(AbstractTestCase.class);
+
+ public AbstractTestCase(String name) {
+ super(name);
+ }
+
+ public AbstractTestCase() {
+ }
+
+ protected void setUp() throws Exception {
+ super.setUp();
+ }
+
+ protected OMElement createOMElement(String xml) {
+ try {
+
+ XMLStreamReader reader = XMLInputFactory.newInstance().createXMLStreamReader(new StringReader(xml));
+ StAXOMBuilder builder = new StAXOMBuilder(reader);
+ OMElement omElement = builder.getDocumentElement();
+ return omElement;
+
+ }
+ catch (XMLStreamException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ protected boolean serialization(String inputXml, MediatorFactory mediatorFactory, MediatorSerializer mediatorSerializer) {
+
+ OMElement inputOM = createOMElement(inputXml);
+ Mediator mediator = mediatorFactory.createMediator(inputOM);
+ OMElement resultOM = mediatorSerializer.serializeMediator(null, mediator);
+ try {
+ assertXMLEqual(resultOM.toString(), inputXml);
+ return true;
+ } catch (SAXException e) {
+ log.error(e);
+ } catch (IOException e) {
+ log.error(e);
+ } catch (ParserConfigurationException e) {
+ log.error(e);
+ }
+ return false;
+ }
+
+ protected boolean serialization(String inputXml, MediatorSerializer mediatorSerializer) {
+ OMElement inputOM = createOMElement(inputXml);
+ Mediator mediator = MediatorFactoryFinder.getInstance().getMediator(inputOM);
+ OMElement resultOM = mediatorSerializer.serializeMediator(null, mediator);
+ try {
+ assertXMLEqual(resultOM.toString(), inputXml);
+ return true;
+ } catch (SAXException e) {
+ log.error(e);
+ } catch (IOException e) {
+ log.error(e);
+ } catch (ParserConfigurationException e) {
+ log.error(e);
+ }
+ return false;
+ }
+
+ protected OMElement getParent() {
+ String parentXML = "<synapse xmlns=\"http://ws.apache.org/ns/synapse\"><definitions></definitions></synapse>";
+ return createOMElement(parentXML);
+ }
+
+ protected boolean compare(OMElement inputElement, OMElement serializedElement) {
+ try {
+
+ assertXMLEqual(inputElement.toString(), serializedElement.toString());
+ return true;
+ } catch (SAXException e) {
+ log.error(e);
+ } catch (IOException e) {
+ log.error(e);
+ } catch (ParserConfigurationException e) {
+ log.error(e);
+ }
+ return false;
+ }
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/AbstractTestCase.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/ClassMediatorSerializationTest.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/ClassMediatorSerializationTest.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/ClassMediatorSerializationTest.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/ClassMediatorSerializationTest.java Sat Mar 17 09:18:32 2007
@@ -1,44 +1,44 @@
-/*
- * 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 org.apache.synapse.config.xml;
-
-/**
- *
- *
- */
-
-public class ClassMediatorSerializationTest extends AbstractTestCase {
-
- ClassMediatorFactory classMediatorFactory;
- ClassMediatorSerializer classMediatorSerializer;
-
- public ClassMediatorSerializationTest() {
- super(ClassMediatorSerializationTest.class.getName());
- classMediatorFactory = new ClassMediatorFactory();
- classMediatorSerializer = new ClassMediatorSerializer();
- }
-
- public void testClassMediatorSerializationSenarioOne() throws Exception {
- String inputXml = "<class xmlns=\"http://ws.apache.org/ns/synapse\" name=\"org.apache.synapse.config.xml.TestMediator\"></class> ";
- assertTrue(serialization(inputXml, classMediatorFactory, classMediatorSerializer));
- assertTrue(serialization(inputXml, classMediatorSerializer));
- }
-
-
-}
+/*
+ * 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 org.apache.synapse.config.xml;
+
+/**
+ *
+ *
+ */
+
+public class ClassMediatorSerializationTest extends AbstractTestCase {
+
+ ClassMediatorFactory classMediatorFactory;
+ ClassMediatorSerializer classMediatorSerializer;
+
+ public ClassMediatorSerializationTest() {
+ super(ClassMediatorSerializationTest.class.getName());
+ classMediatorFactory = new ClassMediatorFactory();
+ classMediatorSerializer = new ClassMediatorSerializer();
+ }
+
+ public void testClassMediatorSerializationSenarioOne() throws Exception {
+ String inputXml = "<class xmlns=\"http://ws.apache.org/ns/synapse\" name=\"org.apache.synapse.config.xml.TestMediator\"></class> ";
+ assertTrue(serialization(inputXml, classMediatorFactory, classMediatorSerializer));
+ assertTrue(serialization(inputXml, classMediatorSerializer));
+ }
+
+
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/ClassMediatorSerializationTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/DropMediatorSerializationTest.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/DropMediatorSerializationTest.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/DropMediatorSerializationTest.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/DropMediatorSerializationTest.java Sat Mar 17 09:18:32 2007
@@ -1,44 +1,44 @@
-/*
- * 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 org.apache.synapse.config.xml;
-
-/**
- *
- *
- */
-
-public class DropMediatorSerializationTest extends AbstractTestCase {
-
- DropMediatorFactory dropMediatorFactory;
- DropMediatorSerializer dropMediatorSerializer;
-
- public DropMediatorSerializationTest() {
- super(DropMediatorSerializationTest.class.getName());
- dropMediatorFactory = new DropMediatorFactory();
- dropMediatorSerializer = new DropMediatorSerializer();
- }
-
- public void testDropMediatorSerializationSenarioOne() throws Exception {
- String inputXml = "<drop xmlns=\"http://ws.apache.org/ns/synapse\" />";
- assertTrue(serialization(inputXml, dropMediatorFactory, dropMediatorSerializer));
- assertTrue(serialization(inputXml, dropMediatorSerializer));
- }
-
-
-}
+/*
+ * 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 org.apache.synapse.config.xml;
+
+/**
+ *
+ *
+ */
+
+public class DropMediatorSerializationTest extends AbstractTestCase {
+
+ DropMediatorFactory dropMediatorFactory;
+ DropMediatorSerializer dropMediatorSerializer;
+
+ public DropMediatorSerializationTest() {
+ super(DropMediatorSerializationTest.class.getName());
+ dropMediatorFactory = new DropMediatorFactory();
+ dropMediatorSerializer = new DropMediatorSerializer();
+ }
+
+ public void testDropMediatorSerializationSenarioOne() throws Exception {
+ String inputXml = "<drop xmlns=\"http://ws.apache.org/ns/synapse\" />";
+ assertTrue(serialization(inputXml, dropMediatorFactory, dropMediatorSerializer));
+ assertTrue(serialization(inputXml, dropMediatorSerializer));
+ }
+
+
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/DropMediatorSerializationTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FaultMediatorSerializationTest.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FaultMediatorSerializationTest.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FaultMediatorSerializationTest.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FaultMediatorSerializationTest.java Sat Mar 17 09:18:32 2007
@@ -1,66 +1,66 @@
-/*
- * 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 org.apache.synapse.config.xml;
-
-/**
- *
- *
- */
-
-public class FaultMediatorSerializationTest extends AbstractTestCase {
-
- FaultMediatorFactory faultMediatorFactory;
- FaultMediatorSerializer faultMediatorSerializer;
- private static final String SOAP11 = "soap11";
- private static final String SOAP12 = "soap12";
- private static final String EMPTY = "";
-
- public FaultMediatorSerializationTest() {
- super(FaultMediatorSerializationTest.class.getName());
- faultMediatorFactory = new FaultMediatorFactory();
- faultMediatorSerializer = new FaultMediatorSerializer();
- }
-
- public void testFaultMediatorSerializationSOAP11() throws Exception {
- String inputXml = getXmlOfMediatorForSOAP11(SOAP11, "ns2:Client", "reason", EMPTY, EMPTY);
- assertTrue(serialization(inputXml, faultMediatorFactory, faultMediatorSerializer));
- assertTrue(serialization(inputXml, faultMediatorSerializer));
- }
-
- public void testFaultMediatorSerializationSOAP12() throws Exception {
- String inputXml = getXmlOfMediatorForSOAP12(SOAP12, "soap:Sender", "reason", EMPTY, EMPTY, EMPTY);
- assertTrue(serialization(inputXml, faultMediatorFactory, faultMediatorSerializer));
- assertTrue(serialization(inputXml, faultMediatorSerializer));
- }
-
- private String getXmlOfMediatorForSOAP11(String version, String attrOfCode, String attrOfReasion
- , String role, String details) throws Exception {
- return "<makefault version=\"" + version + "\" xmlns=\"http://ws.apache.org/ns/synapse\"><code value=\"" + attrOfCode + "\" xmlns:ns2=\"http://ws.apache.org/ns/synapse\"/><reason value=\"" + attrOfReasion + "\"/>" +
- "<role>" + role + "</role><detail>" + details + "</detail></makefault>";
-
- }
-
- private String getXmlOfMediatorForSOAP12(String version, String attrOfCode, String attrOfReasion
- , String node, String role, String details) throws Exception {
- return "<makefault xmlns=\"http://ws.apache.org/ns/synapse\" version=\"" + version + "\"><code value=\"" + attrOfCode + "\" xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"/><reason value=\"" + attrOfReasion + "\"/>" +
- "<node>" + node + "</node><role>" + role + "</role><detail>" + details + "</detail></makefault>";
-
- }
-
-}
+/*
+ * 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 org.apache.synapse.config.xml;
+
+/**
+ *
+ *
+ */
+
+public class FaultMediatorSerializationTest extends AbstractTestCase {
+
+ FaultMediatorFactory faultMediatorFactory;
+ FaultMediatorSerializer faultMediatorSerializer;
+ private static final String SOAP11 = "soap11";
+ private static final String SOAP12 = "soap12";
+ private static final String EMPTY = "";
+
+ public FaultMediatorSerializationTest() {
+ super(FaultMediatorSerializationTest.class.getName());
+ faultMediatorFactory = new FaultMediatorFactory();
+ faultMediatorSerializer = new FaultMediatorSerializer();
+ }
+
+ public void testFaultMediatorSerializationSOAP11() throws Exception {
+ String inputXml = getXmlOfMediatorForSOAP11(SOAP11, "ns2:Client", "reason", EMPTY, EMPTY);
+ assertTrue(serialization(inputXml, faultMediatorFactory, faultMediatorSerializer));
+ assertTrue(serialization(inputXml, faultMediatorSerializer));
+ }
+
+ public void testFaultMediatorSerializationSOAP12() throws Exception {
+ String inputXml = getXmlOfMediatorForSOAP12(SOAP12, "soap:Sender", "reason", EMPTY, EMPTY, EMPTY);
+ assertTrue(serialization(inputXml, faultMediatorFactory, faultMediatorSerializer));
+ assertTrue(serialization(inputXml, faultMediatorSerializer));
+ }
+
+ private String getXmlOfMediatorForSOAP11(String version, String attrOfCode, String attrOfReasion
+ , String role, String details) throws Exception {
+ return "<makefault version=\"" + version + "\" xmlns=\"http://ws.apache.org/ns/synapse\"><code value=\"" + attrOfCode + "\" xmlns:ns2=\"http://ws.apache.org/ns/synapse\"/><reason value=\"" + attrOfReasion + "\"/>" +
+ "<role>" + role + "</role><detail>" + details + "</detail></makefault>";
+
+ }
+
+ private String getXmlOfMediatorForSOAP12(String version, String attrOfCode, String attrOfReasion
+ , String node, String role, String details) throws Exception {
+ return "<makefault xmlns=\"http://ws.apache.org/ns/synapse\" version=\"" + version + "\"><code value=\"" + attrOfCode + "\" xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"/><reason value=\"" + attrOfReasion + "\"/>" +
+ "<node>" + node + "</node><role>" + role + "</role><detail>" + details + "</detail></makefault>";
+
+ }
+
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FaultMediatorSerializationTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FilterMediatorSerializationTest.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FilterMediatorSerializationTest.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FilterMediatorSerializationTest.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FilterMediatorSerializationTest.java Sat Mar 17 09:18:32 2007
@@ -1,49 +1,49 @@
-/*
- * 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 org.apache.synapse.config.xml;
-
-/**
- *
- *
- */
-
-public class FilterMediatorSerializationTest extends AbstractTestCase {
-
- FilterMediatorFactory filterMediatorFactory;
- FilterMediatorSerializer filterMediatorSerializer;
-
- public FilterMediatorSerializationTest() {
- super(FilterMediatorSerializationTest.class.getName());
- filterMediatorFactory = new FilterMediatorFactory();
- filterMediatorSerializer = new FilterMediatorSerializer();
- }
-
- public void testFilterMediatorSerializationSenarioOne() throws Exception {
- String inputXml = "<filter xmlns=\"http://ws.apache.org/ns/synapse\" xpath=\"//*[wsx:symbol='MSFT']\" xmlns:wsx=\"http://services.samples/xsd\"/>";
- assertTrue(serialization(inputXml, filterMediatorFactory, filterMediatorSerializer));
- assertTrue(serialization(inputXml, filterMediatorSerializer));
- }
-
- public void testFilterMediatorSerializationSenarioTwo() throws Exception {
- String inputXml = "<filter xmlns=\"http://ws.apache.org/ns/synapse\" source=\"get-property('To')\" regex=\".*/StockQuote.*\"></filter>";
- assertTrue(serialization(inputXml, filterMediatorFactory, filterMediatorSerializer));
- assertTrue(serialization(inputXml, filterMediatorSerializer));
- }
-
-}
+/*
+ * 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 org.apache.synapse.config.xml;
+
+/**
+ *
+ *
+ */
+
+public class FilterMediatorSerializationTest extends AbstractTestCase {
+
+ FilterMediatorFactory filterMediatorFactory;
+ FilterMediatorSerializer filterMediatorSerializer;
+
+ public FilterMediatorSerializationTest() {
+ super(FilterMediatorSerializationTest.class.getName());
+ filterMediatorFactory = new FilterMediatorFactory();
+ filterMediatorSerializer = new FilterMediatorSerializer();
+ }
+
+ public void testFilterMediatorSerializationSenarioOne() throws Exception {
+ String inputXml = "<filter xmlns=\"http://ws.apache.org/ns/synapse\" xpath=\"//*[wsx:symbol='MSFT']\" xmlns:wsx=\"http://services.samples/xsd\"/>";
+ assertTrue(serialization(inputXml, filterMediatorFactory, filterMediatorSerializer));
+ assertTrue(serialization(inputXml, filterMediatorSerializer));
+ }
+
+ public void testFilterMediatorSerializationSenarioTwo() throws Exception {
+ String inputXml = "<filter xmlns=\"http://ws.apache.org/ns/synapse\" source=\"get-property('To')\" regex=\".*/StockQuote.*\"></filter>";
+ assertTrue(serialization(inputXml, filterMediatorFactory, filterMediatorSerializer));
+ assertTrue(serialization(inputXml, filterMediatorSerializer));
+ }
+
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/FilterMediatorSerializationTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/HeaderMediatorSerializationTest.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/HeaderMediatorSerializationTest.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/HeaderMediatorSerializationTest.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/HeaderMediatorSerializationTest.java Sat Mar 17 09:18:32 2007
@@ -1,48 +1,48 @@
-/*
- * 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 org.apache.synapse.config.xml;
-
-/**
- *
- *
- */
-
-public class HeaderMediatorSerializationTest extends AbstractTestCase {
-
- HeaderMediatorFactory headerMediatorFactory;
- HeaderMediatorSerializer headerMediatorSerializer;
-
- public HeaderMediatorSerializationTest() {
- super(AbstractTestCase.class.getName());
- headerMediatorFactory = new HeaderMediatorFactory();
- headerMediatorSerializer = new HeaderMediatorSerializer();
- }
-
- public void testHeaderMediatorSerializationSenarioOne() throws Exception {
- String inputXml = "<header xmlns=\"http://ws.apache.org/ns/synapse\" name=\"To\" value=\"http://127.0.0.1:10001/axis2/services/Services\"/>";
- assertTrue(serialization(inputXml, headerMediatorFactory, headerMediatorSerializer));
- assertTrue(serialization(inputXml, headerMediatorSerializer));
- }
-
- public void testHeaderMediatorSerializationSenarioTwo() throws Exception {
- String inputXml = "<header xmlns=\"http://ws.apache.org/ns/synapse\" name=\"To\" action=\"remove\"/>";
- assertTrue(serialization(inputXml, headerMediatorFactory, headerMediatorSerializer));
- assertTrue(serialization(inputXml, headerMediatorSerializer));
- }
-}
+/*
+ * 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 org.apache.synapse.config.xml;
+
+/**
+ *
+ *
+ */
+
+public class HeaderMediatorSerializationTest extends AbstractTestCase {
+
+ HeaderMediatorFactory headerMediatorFactory;
+ HeaderMediatorSerializer headerMediatorSerializer;
+
+ public HeaderMediatorSerializationTest() {
+ super(AbstractTestCase.class.getName());
+ headerMediatorFactory = new HeaderMediatorFactory();
+ headerMediatorSerializer = new HeaderMediatorSerializer();
+ }
+
+ public void testHeaderMediatorSerializationSenarioOne() throws Exception {
+ String inputXml = "<header xmlns=\"http://ws.apache.org/ns/synapse\" name=\"To\" value=\"http://127.0.0.1:10001/axis2/services/Services\"/>";
+ assertTrue(serialization(inputXml, headerMediatorFactory, headerMediatorSerializer));
+ assertTrue(serialization(inputXml, headerMediatorSerializer));
+ }
+
+ public void testHeaderMediatorSerializationSenarioTwo() throws Exception {
+ String inputXml = "<header xmlns=\"http://ws.apache.org/ns/synapse\" name=\"To\" action=\"remove\"/>";
+ assertTrue(serialization(inputXml, headerMediatorFactory, headerMediatorSerializer));
+ assertTrue(serialization(inputXml, headerMediatorSerializer));
+ }
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/HeaderMediatorSerializationTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/InMediatorSerializationTest.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/InMediatorSerializationTest.java?view=diff&rev=519363&r1=519362&r2=519363
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/InMediatorSerializationTest.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/InMediatorSerializationTest.java Sat Mar 17 09:18:32 2007
@@ -1,42 +1,42 @@
-/*
- * 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 org.apache.synapse.config.xml;
-
-/**
- *
- *
- */
-
-public class InMediatorSerializationTest extends AbstractTestCase {
-
- InMediatorFactory inMediatorFactory;
- InMediatorSerializer inMediatorSerializer;
-
- public InMediatorSerializationTest() {
- super(InMediatorSerializationTest.class.getName());
- inMediatorFactory = new InMediatorFactory();
- inMediatorSerializer = new InMediatorSerializer();
- }
-
- public void testInMediatorSerialization() throws Exception {
- String inptXml = " <in xmlns=\"http://ws.apache.org/ns/synapse\"><header name=\"To\" value=\"http://64.124.140.30:9090/soap\"/></in>";
- assertTrue(serialization(inptXml, inMediatorFactory, inMediatorSerializer));
- assertTrue(serialization(inptXml, inMediatorSerializer));
- }
-}
+/*
+ * 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 org.apache.synapse.config.xml;
+
+/**
+ *
+ *
+ */
+
+public class InMediatorSerializationTest extends AbstractTestCase {
+
+ InMediatorFactory inMediatorFactory;
+ InMediatorSerializer inMediatorSerializer;
+
+ public InMediatorSerializationTest() {
+ super(InMediatorSerializationTest.class.getName());
+ inMediatorFactory = new InMediatorFactory();
+ inMediatorSerializer = new InMediatorSerializer();
+ }
+
+ public void testInMediatorSerialization() throws Exception {
+ String inptXml = " <in xmlns=\"http://ws.apache.org/ns/synapse\"><header name=\"To\" value=\"http://64.124.140.30:9090/soap\"/></in>";
+ assertTrue(serialization(inptXml, inMediatorFactory, inMediatorSerializer));
+ assertTrue(serialization(inptXml, inMediatorSerializer));
+ }
+}
Propchange: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/InMediatorSerializationTest.java
------------------------------------------------------------------------------
svn:eol-style = native
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org