public class EndpointDefinition extends Object implements AspectConfigurable
Modifier and Type | Field and Description |
---|---|
static String |
DYNAMIC_URL_VALUE |
Constructor and Description |
---|
EndpointDefinition() |
Modifier and Type | Method and Description |
---|---|
void |
addRetryDisabledErrorCode(int code) |
void |
addRetryEnabledErrorCode(int code) |
void |
addSuspendErrorCode(int code) |
void |
addTimeoutErrorCode(int code) |
void |
configure(AspectConfiguration aspectConfiguration)
Configure aspects according to the given configuration
|
void |
disableStatistics() |
void |
disableTracing() |
void |
enableStatistics() |
void |
enableTracing() |
String |
evaluateDynamicEndpointSecurityPolicy(MessageContext synCtx)
Evaluates the ws security policy path dynamically
|
long |
evaluateDynamicEndpointTimeout(MessageContext synCtx) |
String |
getAddress()
This should return the absolute EPR address referenced by the named endpoint.
|
String |
getAddress(MessageContext messageContext)
This should return the absolute EPR address referenced by the named endpoint.
|
String |
getAddressingVersion()
Get the addressing namespace version
|
AspectConfiguration |
getAspectConfiguration()
Get the aspects configuration
|
String |
getCharSetEncoding()
Get the charset encoding for messages sent to the endpoint.
|
String |
getDynamicAddress(MessageContext messageContext)
This should return the absolute EPR address referenced by the named endpoint.
|
SynapsePath |
getDynamicPolicy()
GET expression to evaluate dynamic ws policy
|
SynapsePath |
getDynamicTimeoutExpression() |
long |
getEffectiveTimeout()
Get the effective timeout duration for the endpoint
If endpoint timeout is set explicitly this will return that,
If not global timeout interval is returned
|
SynapseConstants.ENDPOINT_TIMEOUT_TYPE |
getEndpointTimeoutType() |
String |
getFormat() |
String |
getInboundWsSecPolicyKey()
Return the Rampart Security configuration policys' 'key' to be used for inbound messages
(See Rampart)
|
long |
getInitialSuspendDuration()
Get the suspend on fail duration.
|
String |
getOutboundWsSecPolicyKey()
Return the Rampart Security configuration policys' 'key' to be used for outbound messages
(See Rampart)
|
int |
getRetriesOnTimeoutBeforeSuspend() |
List<Integer> |
getRetryDisabledErrorCodes() |
int |
getRetryDurationOnTimeout() |
List<Integer> |
getRetryEnableErrorCodes() |
List<Integer> |
getSuspendErrorCodes() |
long |
getSuspendMaximumDuration() |
float |
getSuspendProgressionFactor() |
int |
getTimeoutAction() |
long |
getTimeoutDuration() |
List<Integer> |
getTimeoutErrorCodes() |
String |
getWsRMPolicyKey()
Deprecated.
|
String |
getWsSecPolicyKey()
Return the Rampart Security configuration policys' 'key' to be used (See Rampart)
|
boolean |
isAddressingOn()
Is WS-A turned on on this endpoint?
|
boolean |
isDynamicPolicy()
Checks ws security policy is a dynamic or static one
|
boolean |
isDynamicTimeoutEndpoint() |
boolean |
isForceGET() |
boolean |
isForcePOX() |
boolean |
isForceREST() |
boolean |
isForceSOAP11() |
boolean |
isForceSOAP12() |
boolean |
isHTTPEndpoint() |
boolean |
isReliableMessagingOn()
Deprecated.
|
boolean |
isReplicationDisabled() |
boolean |
isSecurityOn()
Is WS-Security turned on on this endpoint?
|
boolean |
isStatisticsEnable() |
boolean |
isTracingEnabled() |
boolean |
isUseMTOM() |
boolean |
isUseSeparateListener() |
boolean |
isUseSwa() |
void |
setAddress(String address)
Set an absolute URL as the address for this named endpoint
|
void |
setAddressingOn(boolean addressingOn)
Request that WS-A be turned on/off on this endpoint
|
void |
setAddressingVersion(String addressingVersion)
Set the addressing namespace version
|
void |
setCharSetEncoding(String charSetEncoding)
Set the charset encoding for messages sent to the endpoint.
|
void |
setDynamicPolicy(SynapsePath dynamicPolicy)
Set expression to evaluate dynamic ws policy
|
void |
setDynamicTimeoutExpression(SynapsePath expression) |
void |
setEndpointTimeoutType(SynapseConstants.ENDPOINT_TIMEOUT_TYPE endpointTimeoutType) |
void |
setForceGET(boolean forceGET) |
void |
setForcePOX(boolean forcePOX) |
void |
setForceREST(boolean forceREST) |
void |
setForceSOAP11(boolean forceSOAP11) |
void |
setForceSOAP12(boolean forceSOAP12) |
void |
setFormat(String format) |
void |
setHTTPEndpoint(boolean HTTPEndpoint) |
void |
setInboundWsSecPolicyKey(String inboundWsSecPolicyKey)
Set the Rampart Security configuration policys' 'key' to be used for inbound messages
(See Rampart)
|
void |
setInitialSuspendDuration(long initialSuspendDuration)
Set the suspend on fail duration.
|
void |
setLeafEndpoint(Endpoint leafEndpoint) |
void |
setOutboundWsSecPolicyKey(String outboundWsSecPolicyKey)
Set the Rampart Security configuration policys' 'key' to be used (See Rampart)
|
void |
setReliableMessagingOn(boolean reliableMessagingOn)
Deprecated.
|
void |
setReplicationDisabled(boolean replicationDisabled) |
void |
setRetriesOnTimeoutBeforeSuspend(int retriesOnTimeoutBeforeSuspend) |
void |
setRetryDurationOnTimeout(int retryDurationOnTimeout) |
void |
setSecurityOn(boolean securityOn)
Request that WS-Sec be turned on/off on this endpoint
|
void |
setSuspendMaximumDuration(long suspendMaximumDuration) |
void |
setSuspendProgressionFactor(float suspendProgressionFactor) |
void |
setTimeoutAction(int timeoutAction) |
void |
setTimeoutDuration(long timeoutDuration)
Set the timeout duration.
|
void |
setUseMTOM(boolean useMTOM) |
void |
setUseSeparateListener(boolean b) |
void |
setUseSwa(boolean useSwa) |
void |
setWsRMPolicyKey(String wsRMPolicyKey)
Deprecated.
|
void |
setWsSecPolicyKey(String wsSecPolicyKey)
Set the Rampart Security configuration policys' 'key' to be used (See Rampart)
|
String |
toString() |
public static final String DYNAMIC_URL_VALUE
public void setDynamicTimeoutExpression(SynapsePath expression)
public SynapsePath getDynamicTimeoutExpression()
public boolean isDynamicTimeoutEndpoint()
public long evaluateDynamicEndpointTimeout(MessageContext synCtx)
public String getAddress()
public String getAddress(MessageContext messageContext)
messageContext
- the current message context against the address is computedpublic String getDynamicAddress(MessageContext messageContext)
messageContext
- the current message context against the address is computedpublic void setAddress(String address)
address
- the absolute address to be used@Deprecated public boolean isReliableMessagingOn()
@Deprecated public void setReliableMessagingOn(boolean reliableMessagingOn)
reliableMessagingOn
- a boolean flag indicating RM is on or notpublic boolean isAddressingOn()
public void setAddressingOn(boolean addressingOn)
addressingOn
- a boolean flag indicating addressing is on or notpublic String getAddressingVersion()
public void setAddressingVersion(String addressingVersion)
addressingVersion
- Version of the addressing spec to usepublic boolean isSecurityOn()
public void setSecurityOn(boolean securityOn)
securityOn
- a boolean flag indicating security is on or notpublic String getWsSecPolicyKey()
public void setWsSecPolicyKey(String wsSecPolicyKey)
wsSecPolicyKey
- the Rampart Security configuration policys' 'key' to be usedpublic String getInboundWsSecPolicyKey()
public void setInboundWsSecPolicyKey(String inboundWsSecPolicyKey)
inboundWsSecPolicyKey
- the Rampart Security configuration policys' 'key' to be usedpublic String getOutboundWsSecPolicyKey()
public void setOutboundWsSecPolicyKey(String outboundWsSecPolicyKey)
outboundWsSecPolicyKey
- the Rampart Security configuration policys' 'key' to be used@Deprecated public String getWsRMPolicyKey()
@Deprecated public void setWsRMPolicyKey(String wsRMPolicyKey)
wsRMPolicyKey
- the WS-RM configuration policys' 'key' to be usedpublic void setUseSeparateListener(boolean b)
public boolean isUseSeparateListener()
public void setForcePOX(boolean forcePOX)
public boolean isForcePOX()
public boolean isForceGET()
public void setForceGET(boolean forceGET)
public void setForceSOAP11(boolean forceSOAP11)
public boolean isForceSOAP11()
public void setForceSOAP12(boolean forceSOAP12)
public boolean isForceSOAP12()
public boolean isForceREST()
public void setForceREST(boolean forceREST)
public boolean isUseMTOM()
public void setUseMTOM(boolean useMTOM)
public boolean isUseSwa()
public void setUseSwa(boolean useSwa)
public long getTimeoutDuration()
public long getEffectiveTimeout()
public void setTimeoutDuration(long timeoutDuration)
timeoutDuration
- a duration in millisecondspublic int getTimeoutAction()
public void setTimeoutAction(int timeoutAction)
public String getFormat()
public void setFormat(String format)
public String getCharSetEncoding()
public void setCharSetEncoding(String charSetEncoding)
charSetEncoding
- the charset encoding or null
public long getInitialSuspendDuration()
public void setInitialSuspendDuration(long initialSuspendDuration)
initialSuspendDuration
- a duration in millisecondspublic float getSuspendProgressionFactor()
public void setSuspendProgressionFactor(float suspendProgressionFactor)
public long getSuspendMaximumDuration()
public void setSuspendMaximumDuration(long suspendMaximumDuration)
public int getRetriesOnTimeoutBeforeSuspend()
public void setRetriesOnTimeoutBeforeSuspend(int retriesOnTimeoutBeforeSuspend)
public int getRetryDurationOnTimeout()
public void setRetryDurationOnTimeout(int retryDurationOnTimeout)
public boolean isReplicationDisabled()
public void setReplicationDisabled(boolean replicationDisabled)
public void addSuspendErrorCode(int code)
public void addTimeoutErrorCode(int code)
public void addRetryDisabledErrorCode(int code)
public void addRetryEnabledErrorCode(int code)
public boolean isHTTPEndpoint()
public void setHTTPEndpoint(boolean HTTPEndpoint)
public void setLeafEndpoint(Endpoint leafEndpoint)
public boolean isStatisticsEnable()
public void disableStatistics()
public void enableStatistics()
public boolean isTracingEnabled()
public void disableTracing()
public void enableTracing()
public void configure(AspectConfiguration aspectConfiguration)
AspectConfigurable
configure
in interface AspectConfigurable
aspectConfiguration
- AspectConfiguration instancepublic AspectConfiguration getAspectConfiguration()
AspectConfigurable
getAspectConfiguration
in interface AspectConfigurable
public SynapseConstants.ENDPOINT_TIMEOUT_TYPE getEndpointTimeoutType()
public void setEndpointTimeoutType(SynapseConstants.ENDPOINT_TIMEOUT_TYPE endpointTimeoutType)
public SynapsePath getDynamicPolicy()
public void setDynamicPolicy(SynapsePath dynamicPolicy)
dynamicPolicy
- SynapsePath to the policypublic boolean isDynamicPolicy()
public String evaluateDynamicEndpointSecurityPolicy(MessageContext synCtx)
synCtx
- MessageContextCopyright © 2005–2019 Apache Software Foundation. All rights reserved.