Skip to content

Commit

Permalink
address reviewed changes
Browse files Browse the repository at this point in the history
  • Loading branch information
chathuranga-jayanath-99 committed Dec 8, 2024
1 parent b1367aa commit be72bef
Showing 1 changed file with 8 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import org.apache.synapse.SynapseConstants;
import org.apache.synapse.aspects.statistics.StatisticsConfigurable;
import org.apache.synapse.config.xml.XMLConfigConstants;
import org.apache.synapse.endpoints.EPConstants;
import org.apache.synapse.endpoints.EndpointDefinition;

public class EndpointDefinitionSerializer {
Expand Down Expand Up @@ -102,7 +103,7 @@ public void serializeEndpointDefinition(EndpointDefinition endpointDefinition,
element.addChild(sec);
}

if (!endpointDefinition.getTimeoutAction().equals("none") || endpointDefinition.isTimeoutActionDynamic() ||
if (!endpointDefinition.getTimeoutAction().equals(EPConstants.NEVER) || endpointDefinition.isTimeoutActionDynamic() ||
isStringPositiveNumber(endpointDefinition.getTimeoutDuration()) || endpointDefinition.isDynamicTimeoutEndpoint()) {

OMElement timeout = fac.createOMElement(
Expand All @@ -120,15 +121,16 @@ public void serializeEndpointDefinition(EndpointDefinition endpointDefinition,
timeout.addChild(duration);
}

if (!endpointDefinition.getTimeoutAction().equals("none") || endpointDefinition.isTimeoutActionDynamic()) {
if (!endpointDefinition.getTimeoutAction().equals(
EPConstants.NEVER) || endpointDefinition.isTimeoutActionDynamic()) {
OMElement action = fac.createOMElement("responseAction", SynapseConstants.SYNAPSE_OMNAMESPACE);
if (endpointDefinition.isTimeoutActionDynamic()) {
action.setText('{' + endpointDefinition.getTimeoutAction() + '}');
} else {
if (endpointDefinition.getTimeoutAction().equals("discard")) {
action.setText("discard");
} else if (endpointDefinition.getTimeoutAction().equals("fault")) {
action.setText("fault");
if (endpointDefinition.getTimeoutAction().equals(EPConstants.DISCARD)) {
action.setText(EPConstants.DISCARD);
} else if (endpointDefinition.getTimeoutAction().equals(EPConstants.FAULT)) {
action.setText(EPConstants.FAULT);
}
}
timeout.addChild(action);
Expand Down

0 comments on commit be72bef

Please sign in to comment.