public class LoadbalanceEndpoint extends AbstractEndpoint
anonymous, artifactContainerName, CHILDREN_JSON_ATT, errorHandler, fileName, initialized, isClusteringEnabled, log, NAME_JSON_ATT, trace, TYPE_JSON_ATT
Constructor and Description |
---|
LoadbalanceEndpoint() |
Modifier and Type | Method and Description |
---|---|
protected void |
createJsonRepresentation() |
void |
destroy()
This method should implement the destroying of the
implemented parts of the configuration.
|
LoadbalanceAlgorithm |
getAlgorithm() |
java.util.List<org.apache.axis2.clustering.Member> |
getMembers() |
protected Endpoint |
getNextChild(MessageContext synCtx) |
void |
init(SynapseEnvironment synapseEnvironment)
This method should implement the initialization of the
implemented parts of the configuration.
|
boolean |
isBuildMessageAtt() |
boolean |
isFailover() |
boolean |
isInitialized()
NOTE: Override org.apache.synapse.endpoints.AbstractEndpoint#isInitialized() to ensure return true only after LB
Endpoint get fully initialized.
|
void |
onChildEndpointFail(Endpoint endpoint,
MessageContext synMessageContext)
Endpoints that contain other endpoints should implement this method.
|
boolean |
readyToSend()
If this endpoint is in inactive state, checks if all immediate child endpoints are still
failed.
|
void |
send(MessageContext synCtx)
Sends the message context according to an endpoint specific behavior.
|
void |
setAlgorithm(LoadbalanceAlgorithm algorithm) |
void |
setBuildMessageAtt(boolean build) |
void |
setBuildMessageAttAvailable(boolean available) |
void |
setFailover(boolean failover) |
void |
setMembers(java.util.List<org.apache.axis2.clustering.Member> members) |
void |
startApplicationMembershipTimer() |
addProperties, addProperty, evaluateProperties, executeEpTypeSpecificFunctions, getArtifactContainerName, getChildren, getCommentsList, getContext, getDefinition, getDescription, getEndpointChildrenAsJson, getErrorHandler, getFileName, getIsEdited, getJsonRepresentation, getMetricsMBean, getName, getParentEndpoint, getProperties, getProperty, getReportingName, handleException, handleException, handleException, informFailure, isAnonymous, isLeafEndpoint, isRetry, isSuspendFault, isTimeout, isTraceOn, isTraceOrDebugOn, logOnChildEndpointFail, logSetter, onFault, onSuccess, prepareForEndpointStatistics, removeProperty, setAdvancedProperties, setAnonymous, setArtifactContainerName, setChildren, setCommentsList, setComponentStatisticsId, setContentAware, setDefinition, setDescription, setEnableMBeanStats, setErrorHandler, setErrorOnMessage, setFileName, setForceBuildMC, setIsEdited, setName, setParentEndpoint, toString, traceOrDebug
executeExtendedSynapseHandlerOnFault, getStackTrace, handleFault, handleFault
public void init(SynapseEnvironment synapseEnvironment)
ManagedLifecycle
init
in interface ManagedLifecycle
init
in class AbstractEndpoint
synapseEnvironment
- SynapseEnvironment to be used for initializationpublic void destroy()
ManagedLifecycle
destroy
in interface ManagedLifecycle
destroy
in class AbstractEndpoint
public boolean isInitialized()
isInitialized
in interface Endpoint
isInitialized
in class AbstractEndpoint
protected void createJsonRepresentation()
createJsonRepresentation
in class AbstractEndpoint
public void send(MessageContext synCtx)
Endpoint
send
in interface Endpoint
send
in class AbstractEndpoint
synCtx
- MessageContext to be sent.public boolean readyToSend()
readyToSend
in interface Endpoint
readyToSend
in class AbstractEndpoint
public void onChildEndpointFail(Endpoint endpoint, MessageContext synMessageContext)
Endpoint
onChildEndpointFail
in interface Endpoint
onChildEndpointFail
in class AbstractEndpoint
endpoint
- The child endpoint which caused the exception.synMessageContext
- MessageContext that was used in the failed attempt.public boolean isFailover()
public boolean isBuildMessageAtt()
public void setFailover(boolean failover)
public LoadbalanceAlgorithm getAlgorithm()
public void setAlgorithm(LoadbalanceAlgorithm algorithm)
protected Endpoint getNextChild(MessageContext synCtx)
public void setMembers(java.util.List<org.apache.axis2.clustering.Member> members)
public java.util.List<org.apache.axis2.clustering.Member> getMembers()
public void startApplicationMembershipTimer()
public void setBuildMessageAtt(boolean build)
public void setBuildMessageAttAvailable(boolean available)
Copyright © 2005-2021 Apache Software Foundation. All Rights Reserved.