public interface SynapseEnvironment
Modifier and Type | Method and Description |
---|---|
void |
addUnavailableArtifactRef(java.lang.String key)
Add an artifact reference not available in the environment.
|
void |
clearUnavailabilityOfArtifact(java.lang.String key)
Clear unavailability of an artifact if it is
previously marked as unavailable in the environment
|
MessageContext |
createMessageContext()
Creates a new Synapse
MessageContext instance. |
org.apache.axiom.util.blob.OverflowBlob |
createOverflowBlob()
Creates a new
TemporaryData instance for the temp storage requirements |
java.util.concurrent.ExecutorService |
getExecutorService()
This is used by anyone who needs access to a SynapseThreadPool.
|
long |
getGlobalTimeout()
Get the global timeout interval for callbacks
|
MessageDataStore |
getMessageDataStore()
This method returns message data store which holds a queue of event holder objects.
|
ServerContextInformation |
getServerContextInformation()
Get the information about the synapse environment.
|
SynapseConfiguration |
getSynapseConfiguration()
Retrieves the
SynapseConfiguration from the environment |
SynapseDebugManager |
getSynapseDebugManager()
Retrieve the
SynapseDebugManager from the
environment . |
java.util.List<SynapseHandler> |
getSynapseHandlers()
Get all synapse handlers
|
org.apache.synapse.task.SynapseTaskManager |
getTaskManager()
Retrieve the
SynapseTaskManager from the
environment . |
TenantInfoConfigurator |
getTenantInfoConfigurator() |
java.util.Map<java.lang.String,SynapseXpathFunctionContextProvider> |
getXpathFunctionExtensions()
Get all Xpath Extension objects for Function contexts
|
java.util.Map<javax.xml.namespace.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 |
injectInbound(MessageContext smc,
SequenceMediator seq,
boolean sequential)
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 |
injectMessage(MessageContext smc,
SequenceMediator seq)
Inject message to the sequence in synchronous manner
|
boolean |
isContinuationEnabled()
Whether continuation is enabled in the environment
|
boolean |
isDebuggerEnabled()
Whether debugging is enabled in the environment.
|
boolean |
isInitialized()
Has the Synapse Environment properly initialized?
|
void |
registerSynapseHandler(SynapseHandler handler)
Register a synapse handler to the synapse environment
|
void |
removeUnavailableArtifactRef(java.lang.String key)
Remove the artifact reference which is marked as unavailable in environment
from the unavailable list
|
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 |
updateCallMediatorCount(boolean isIncrement)
Increment/Decrement the Call mediator count in the environment by 1
|
boolean injectMessage(MessageContext smc)
smc
- - Synapse MessageContext to be injectedvoid injectAsync(MessageContext smc, SequenceMediator seq)
smc
- - Synapse message context to be injectedseq
- - Sequence to be used for mediationboolean injectInbound(MessageContext smc, SequenceMediator seq, boolean sequential)
smc
- - Synapse message context to be injectedseq
- - Sequence to be used for mediationsequential
- - Injection behaviorvoid send(EndpointDefinition endpoint, MessageContext smc)
endpoint
- - Endpoint to be used for sendingsmc
- - Synapse MessageContext to be sentMessageContext createMessageContext()
MessageContext
instance.org.apache.axiom.util.blob.OverflowBlob createOverflowBlob()
TemporaryData
instance for the temp storage requirementsMessageDataStore getMessageDataStore()
java.util.concurrent.ExecutorService getExecutorService()
boolean isInitialized()
void setInitialized(boolean state)
state
- true means ready for processingSynapseConfiguration getSynapseConfiguration()
SynapseConfiguration
from the environment
org.apache.synapse.task.SynapseTaskManager getTaskManager()
SynapseTaskManager
from the
environment
.ServerContextInformation getServerContextInformation()
ServerContextInformation
of this synapse environmentjava.util.Map<java.lang.String,SynapseXpathFunctionContextProvider> getXpathFunctionExtensions()
java.util.Map<javax.xml.namespace.QName,SynapseXpathVariableResolver> getXpathVariableExtensions()
TenantInfoConfigurator getTenantInfoConfigurator()
void updateCallMediatorCount(boolean isIncrement)
isIncrement
- whether to increment the countboolean isContinuationEnabled()
void addUnavailableArtifactRef(java.lang.String key)
key
- artifact reference keyvoid removeUnavailableArtifactRef(java.lang.String key)
key
- artifact reference keyvoid clearUnavailabilityOfArtifact(java.lang.String key)
key
- artifact reference keyboolean injectMessage(MessageContext smc, SequenceMediator seq)
smc
- - Synapse message context to be injectedseq
- - Sequence to be used for mediationjava.util.List<SynapseHandler> getSynapseHandlers()
void registerSynapseHandler(SynapseHandler handler)
handler
- synapse handlerlong getGlobalTimeout()
boolean isDebuggerEnabled()
SynapseDebugManager getSynapseDebugManager()
SynapseDebugManager
from the
environment
.Copyright © 2005-2022 Apache Software Foundation. All Rights Reserved.