Author: ruwan
Date: Tue Jul 1 18:43:56 2008
New Revision: 673260
URL: http://svn.apache.org/viewvc?rev=673260&view=rev
Log:
Fixing the issue SYNAPSE-382,
* getSynapseConfiguration is added to the SynapseEnvironment interface
* getAxis2ConfigurationContext has been added to the Axis2SynapseEnvironment
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java?rev=673260&r1=673259&r2=673260&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
Tue Jul 1 18:43:56 2008
@@ -179,12 +179,13 @@
}
public void injectAsync(final MessageContext synCtx, SequenceMediator seq)
{
+
if (log.isDebugEnabled()) {
log.debug("Injecting MessageContext for asynchronous mediation
using the : "
+ (seq.getName() == null? "Anonymous" : seq.getName()) + "
Sequence");
}
synCtx.setEnvironment(this);
- // todo: do we need to have this in here ? ruwan
+
if (synCtx.isResponse()) {
//Process statistics related to a sequence which has send mediator
as a child,end point
StatisticsUtils.processEndPointStatistics(synCtx);
@@ -193,7 +194,6 @@
}
executorService.execute(new MediatorWorker(seq, synCtx));
-
}
/**
@@ -321,6 +321,7 @@
/**
* Has this environment properly initialized?
+ *
* @return true if ready for processing
*/
public boolean isInitialized() {
@@ -329,12 +330,31 @@
/**
* Mark this environment as ready for processing
+ *
* @param state true means ready for processing
*/
public void setInitialized(boolean state) {
this.initialized = state;
}
+ /**
+ * Retrieves the [EMAIL PROTECTED] SynapseConfiguration} from the
<code>environment</code>
+ *
+ * @return synapseConfig associated with the enviorenment
+ */
+ public SynapseConfiguration getSynapseConfiguration() {
+ return this.synapseConfig;
+ }
+
+ /**
+ * Retrieves the [EMAIL PROTECTED] ConfigurationContext} associated with
this <code>axis2SynapseEnv</code>
+ *
+ * @return configContext of the axis2 synapse environment
+ */
+ public ConfigurationContext getAxis2ConfigurationContext() {
+ return this.configContext;
+ }
+
private void handleException(String message, Throwable e) {
log.error(message, e);
throw new SynapseException(message, e);