Package | Description |
---|---|
org.apache.synapse | |
org.apache.synapse.config | |
org.apache.synapse.config.xml |
Factories and serializers for XML based configuration.
|
org.apache.synapse.config.xml.endpoints | |
org.apache.synapse.core.axis2 | |
org.apache.synapse.endpoints | |
org.apache.synapse.endpoints.algorithms | |
org.apache.synapse.endpoints.dispatch | |
org.apache.synapse.mediators.bsf | |
org.apache.synapse.mediators.builtin | |
org.apache.synapse.mediators.eip |
Modifier and Type | Method and Description |
---|---|
Endpoint |
MessageContext.getEndpoint(String key)
Return the endpoint with the given key from the configuration, or the local message
context.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
SynapseConfiguration.getEndpoint(String key)
Get the definition of the endpoint with the given key
|
Modifier and Type | Method and Description |
---|---|
Map<String,Endpoint> |
SynapseConfiguration.getDefinedEndpoints()
Returns the map of defined endpoints in the configuration excluding the
fetched endpoints from remote registry
|
Modifier and Type | Method and Description |
---|---|
void |
SynapseConfiguration.addEndpoint(String key,
Endpoint endpoint)
Define a named endpoint with the given key.
|
void |
SynapseObserver.endpointAdded(Endpoint endpoint)
Event fired when an endpoint is added to the configuration
|
void |
AbstractSynapseObserver.endpointAdded(Endpoint endpoint) |
void |
SynapseObserver.endpointRemoved(Endpoint endpoint)
Event fired when an endpoint is removed from the configuration
|
void |
AbstractSynapseObserver.endpointRemoved(Endpoint endpoint) |
void |
SynapseConfiguration.updateEndpoint(String key,
Endpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
static Endpoint |
SynapseXMLConfigurationFactory.defineEndpoint(SynapseConfiguration config,
org.apache.axiom.om.OMElement ele,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
org.apache.axiom.om.OMElement |
MultiXMLConfigurationSerializer.serializeEndpoint(Endpoint epr,
SynapseConfiguration synapseConfig,
org.apache.axiom.om.OMElement parent) |
Modifier and Type | Method and Description |
---|---|
protected Endpoint |
IndirectEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
FailoverEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
Endpoint |
TemplateEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement endpointElement,
boolean a,
Properties properties) |
protected Endpoint |
DynamicLoadbalanceEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
DefaultEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
ResolvingEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
LoadbalanceEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
ServiceDynamicLoadbalanceEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
ClassEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected abstract Endpoint |
EndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties)
Creates the Endpoint implementation for the given XML endpoint configuration.
|
protected Endpoint |
RecipientListEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
AddressEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
SALoadbalanceEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
protected Endpoint |
WSDLEndpointFactory.createEndpoint(org.apache.axiom.om.OMElement epConfig,
boolean anonymousEndpoint,
Properties properties) |
static Endpoint |
EndpointFactory.getEndpointFromElement(org.apache.axiom.om.OMElement elem,
boolean isAnonymous,
Properties properties)
Core method which is exposed for the external use, and this will find the proper
EndpointFactory and create the endpoint which is of the format Endpoint . |
static Endpoint |
EndpointFactory.getEndpointFromElement(org.apache.axiom.om.OMElement elem,
DefinitionFactory factory,
boolean isAnonymous,
Properties properties)
Core method which is exposed for the external use, and this will find the proper
EndpointFactory and create the endpoint which is of the format Endpoint .However
definition for this endpoint will be built using a custom Endpoint Defn factory. |
Modifier and Type | Method and Description |
---|---|
protected ArrayList<Endpoint> |
EndpointFactory.getEndpoints(org.apache.axiom.om.OMElement listEndpointElement,
Endpoint parent,
Properties properties)
Helper method to construct children endpoints
|
Modifier and Type | Method and Description |
---|---|
static org.apache.axiom.om.OMElement |
EndpointSerializer.getElementFromEndpoint(Endpoint endpoint)
Core method which is exposed to the external use, and serializes the
Endpoint to the
XML format |
protected ArrayList<Endpoint> |
EndpointFactory.getEndpoints(org.apache.axiom.om.OMElement listEndpointElement,
Endpoint parent,
Properties properties)
Helper method to construct children endpoints
|
static EndpointSerializer |
EndpointSerializer.getEndpointSerializer(Endpoint endpoint)
Returns the EndpointSerializer implementation for the given endpoint.
|
protected void |
EndpointSerializer.serializeCommonAttributes(Endpoint endpoint,
org.apache.axiom.om.OMElement element) |
protected abstract org.apache.axiom.om.OMElement |
EndpointSerializer.serializeEndpoint(Endpoint endpoint)
Serializes the given endpoint implementation to an XML object.
|
protected org.apache.axiom.om.OMElement |
FailoverEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
protected org.apache.axiom.om.OMElement |
LoadbalanceEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
protected org.apache.axiom.om.OMElement |
IndirectEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
org.apache.axiom.om.OMElement |
TemplateEndpointSerializer.serializeEndpoint(Endpoint epr) |
protected org.apache.axiom.om.OMElement |
DefaultEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
protected org.apache.axiom.om.OMElement |
SALoadbalanceEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
protected org.apache.axiom.om.OMElement |
RecipientListEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
protected org.apache.axiom.om.OMElement |
AddressEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
protected org.apache.axiom.om.OMElement |
ResolvingEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
protected org.apache.axiom.om.OMElement |
DynamicLoadbalanceEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
protected org.apache.axiom.om.OMElement |
WSDLEndpointSerializer.serializeEndpoint(Endpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
Axis2MessageContext.getEndpoint(String key) |
Endpoint |
ProxyService.getTargetInLineEndpoint() |
Modifier and Type | Method and Description |
---|---|
MessageContext |
Axis2BlockingClient.send(Endpoint endpoint,
MessageContext synapseInMsgCtx)
Send the message to a given Leaf endpoint (Address/WSDL/Default) in a blocking manner
|
void |
ProxyService.setTargetInLineEndpoint(Endpoint targetInLineEndpoint) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEndpoint
An abstract base class for all Endpoint implementations
|
class |
AddressEndpoint
This class represents an actual endpoint to send the message.
|
class |
DefaultEndpoint
This class represents an endpoint with the EPR as the 'To' header of the message.
|
class |
DynamicLoadbalanceEndpoint
Represents a dynamic load balance endpoint.
|
class |
FailoverEndpoint
FailoverEndpoint can have multiple child endpoints.
|
class |
IndirectEndpoint
This class represents a real endpoint referred by a key.
|
class |
LoadbalanceEndpoint
A Load balance endpoint contains multiple child endpoints.
|
class |
RecipientListEndpoint
A Recipient List endpoint can contain multiple child endpoints or member elements.
|
class |
ResolvingEndpoint |
class |
SALoadbalanceEndpoint
SALoadbalanceEndpoint supports session affinity based load balancing.
|
class |
ServiceDynamicLoadbalanceEndpoint
Represents a dynamic load balance endpoint.
|
class |
TemplateEndpoint |
class |
WSDLEndpoint
WSDLEndpoint represents the endpoints built using a WSDL document.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
Template.create(TemplateEndpoint templateEndpoint,
Properties properties) |
protected Endpoint |
LoadbalanceEndpoint.getNextChild(MessageContext synCtx) |
Endpoint |
AbstractEndpoint.getParentEndpoint() |
Endpoint |
IndirectEndpoint.getRealEndpoint(MessageContext synCtx)
Get the real endpoint
|
Modifier and Type | Method and Description |
---|---|
List<Endpoint> |
IndirectEndpoint.getChildren() |
List<Endpoint> |
Endpoint.getChildren()
Get the children of this endpoint
|
List<Endpoint> |
AbstractEndpoint.getChildren() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractEndpoint.logOnChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
LoadbalanceEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
Endpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext)
Endpoints that contain other endpoints should implement this method.
|
void |
RecipientListEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
SALoadbalanceEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synCtx)
It is logically incorrect to failover a session affinity endpoint after the session has started.
|
void |
AbstractEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
void |
FailoverEndpoint.onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext) |
abstract void |
DynamicLoadbalanceFaultHandler.setCurrentEp(Endpoint currentEp) |
void |
EndpointDefinition.setLeafEndpoint(Endpoint leafEndpoint) |
void |
Endpoint.setParentEndpoint(Endpoint parentEndpoint)
Sets the parent endpoint for the current endpoint.
|
void |
AbstractEndpoint.setParentEndpoint(Endpoint parentEndpoint) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractEndpoint.setChildren(List<Endpoint> children) |
Constructor and Description |
---|
EndpointView(String endpointName,
Endpoint endpoint)
Create a new MBean to manage the given endpoint
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
WeightedRRLCAlgorithm.getNextEndpoint(MessageContext messageContext,
AlgorithmContext algorithmContext) |
Endpoint |
WeightedRoundRobin.getNextEndpoint(MessageContext synapseMessageContext,
AlgorithmContext algorithmContext) |
Endpoint |
RoundRobin.getNextEndpoint(MessageContext synCtx,
AlgorithmContext algorithmContext)
Choose an active endpoint using the round robin algorithm.
|
Endpoint |
LoadbalanceAlgorithm.getNextEndpoint(MessageContext synapseMessageContext,
AlgorithmContext algorithmContext)
This method returns the next node according to the algorithm implementation.
|
Modifier and Type | Method and Description |
---|---|
void |
WeightedRRLCAlgorithm.setLoadBalanceEndpoint(Endpoint endpoint) |
void |
WeightedRoundRobin.setLoadBalanceEndpoint(Endpoint endpoint) |
void |
RoundRobin.setLoadBalanceEndpoint(Endpoint endpoint) |
void |
LoadbalanceAlgorithm.setLoadBalanceEndpoint(Endpoint endpoint)
Set the loadbalance endpoint
|
Modifier and Type | Method and Description |
---|---|
void |
WeightedRRLCAlgorithm.setEndpoints(List<Endpoint> endpoints) |
void |
WeightedRoundRobin.setEndpoints(List<Endpoint> endpoints) |
void |
RoundRobin.setEndpoints(List<Endpoint> endpoints) |
void |
LoadbalanceAlgorithm.setEndpoints(List<Endpoint> endpoints)
Set the endpoints
|
Modifier and Type | Method and Description |
---|---|
List<Endpoint> |
SALSessions.getChildEndpoints(SessionInformation information)
Returns endpoint sequence related to the given session
|
List<Endpoint> |
SessionInformation.getEndpointList() |
List<Endpoint> |
Dispatcher.getEndpoints(SessionInformation sessionInformation)
Returns the endpoint sequence associated with current session with out root
|
List<Endpoint> |
AbstractDispatcher.getEndpoints(SessionInformation sessionInformation) |
Modifier and Type | Method and Description |
---|---|
void |
SALSessions.registerChildren(Endpoint endpoint,
List<Endpoint> endpoints)
This method only use in a clustered environment.
|
Modifier and Type | Method and Description |
---|---|
void |
SALSessions.registerChildren(Endpoint endpoint,
List<Endpoint> endpoints)
This method only use in a clustered environment.
|
Constructor and Description |
---|
SessionInformation(String id,
List<Endpoint> endpointList,
long expiryTime) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
ScriptMessageContext.getEndpoint(String key) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
SendMediator.getEndpoint() |
Endpoint |
CalloutMediator.getEndpoint()
Get the defined endpoint
|
Modifier and Type | Method and Description |
---|---|
void |
SendMediator.setEndpoint(Endpoint endpoint) |
void |
CalloutMediator.setEndpoint(Endpoint endpoint)
Set the defined endpoint
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
Target.getEndpoint() |
Modifier and Type | Method and Description |
---|---|
void |
Target.setEndpoint(Endpoint endpoint) |
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.