org.apache.synapse.core
Interface SynapseEnvironment

All Known Implementing Classes:
Axis2SynapseEnvironment

public interface SynapseEnvironment

The SynapseEnvironment allows access into the the host SOAP engine. It allows the sending of messages, class loader access etc.


Method Summary
 MessageContext createMessageContext()
          Creates a new Synapse MessageContext instance.
 OverflowBlob createOverflowBlob()
          Creates a new TemporaryData instance for the temp storage requirements
 ExecutorService getExecutorService()
          This is used by anyone who needs access to a SynapseThreadPool.
 ServerContextInformation getServerContextInformation()
          Get the information about the synapse environment.
 StatisticsCollector getStatisticsCollector()
          This method returns the StatisticsCollector responsible for collecting stats for this synapse instance.
 SynapseConfiguration getSynapseConfiguration()
          Retrieves the SynapseConfiguration from the environment
 SynapseTaskManager getTaskManager()
          Retrieve the SynapseTaskManager from the environment.
 Map<QName,SynapseXpathFunctionContextProvider> getXpathFunctionExtensions()
          Get all Xpath Extension objects for Function contexts
 Map<QName,SynapseXpathVariableResolver> getXpathVariableExtensions()
          Get all Xpath Extension objects for Variable contexts
 void injectAsync(MessageContext smc, SequenceMediator seq)
          This method injects a new message into the Synapse engine for the mediation by the specified sequence.
 boolean injectMessage(MessageContext smc)
          This method injects a new message into the Synapse engine.
 boolean isInitialized()
          Has the Synapse Environment properly initialized?
 void send(EndpointDefinition endpoint, MessageContext smc)
          This method allows a message to be sent through the underlying SOAP engine.
 void setInitialized(boolean state)
          Set the environment as ready for message processing
 void setStatisticsCollector(StatisticsCollector statisticsCollector)
          Deprecated. 
 

Method Detail

injectMessage

boolean injectMessage(MessageContext smc)
This method injects a new message into the Synapse engine. This is used by the underlying SOAP engine to inject messages into Synapse for mediation. e.g. The SynapseMessageReceiver used by Axis2 invokes this to inject new messages

Parameters:
smc - - Synapse MessageContext to be injected
Returns:
boolean true if the message processing should be continued and false if it should be aborted

injectAsync

void injectAsync(MessageContext smc,
                 SequenceMediator seq)
This method injects a new message into the Synapse engine for the mediation by the specified sequence. This is used by custom mediation tasks like splitting message in EIP mediation. This method will do the mediation asynchronously using a separate thread from the environment thread pool

Parameters:
smc - - Synapse message context to be injected
seq - - Sequence to be used for mediation

send

void send(EndpointDefinition endpoint,
          MessageContext smc)
This method allows a message to be sent through the underlying SOAP engine. This will send request messages on (forward), and send the response messages back to the client

Parameters:
endpoint - - Endpoint to be used for sending
smc - - Synapse MessageContext to be sent

createMessageContext

MessageContext createMessageContext()
Creates a new Synapse MessageContext instance.

Returns:
a MessageContext

createOverflowBlob

OverflowBlob createOverflowBlob()
Creates a new TemporaryData instance for the temp storage requirements

Returns:
a TemporaryData created from the parameters provided in the synapse.properties

getStatisticsCollector

StatisticsCollector getStatisticsCollector()
This method returns the StatisticsCollector responsible for collecting stats for this synapse instance.

Returns:
Returns the StatisticsCollector

setStatisticsCollector

@Deprecated
void setStatisticsCollector(StatisticsCollector statisticsCollector)
Deprecated. 

To set the StatisticsCollector to the environment

Parameters:
statisticsCollector - - StatisticsCollector to be set

getExecutorService

ExecutorService getExecutorService()
This is used by anyone who needs access to a SynapseThreadPool. It offers the ability to start work.

Returns:
Returns the ExecutorService

isInitialized

boolean isInitialized()
Has the Synapse Environment properly initialized?

Returns:
true if the environment is ready for processing

setInitialized

void setInitialized(boolean state)
Set the environment as ready for message processing

Parameters:
state - true means ready for processing

getSynapseConfiguration

SynapseConfiguration getSynapseConfiguration()
Retrieves the SynapseConfiguration from the environment

Returns:
configuration of the synapse

getTaskManager

SynapseTaskManager getTaskManager()
Retrieve the SynapseTaskManager from the environment.

Returns:
SynapseTaskManager of this synapse environment

getServerContextInformation

ServerContextInformation getServerContextInformation()
Get the information about the synapse environment.

Returns:
ServerContextInformation of this synapse environment

getXpathFunctionExtensions

Map<QName,SynapseXpathFunctionContextProvider> getXpathFunctionExtensions()
Get all Xpath Extension objects for Function contexts

Returns:
Map containing xpath extension objects

getXpathVariableExtensions

Map<QName,SynapseXpathVariableResolver> getXpathVariableExtensions()
Get all Xpath Extension objects for Variable contexts

Returns:
Map containing xpath extension objects


Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.