Package org.apache.synapse.transport.passthru.config

Class PassThroughConfiguration

java.lang.Object
org.apache.synapse.transport.passthru.config.PassThroughConfiguration
public class PassThroughConfiguration extends Object
This class encapsulates pass-through http transport tuning configurations specified via a configurations file or system properties.

  • Method Details

    • getInstance

      public static PassThroughConfiguration getInstance()

    • reload

      public void reload()
      Reloads properties from "passthru-http.properties", picking up the current CONF_LOCATION.

    • getWorkerPoolCoreSize

      public int getWorkerPoolCoreSize()

    • getSecondaryWorkerPoolCoreSize

      public int getSecondaryWorkerPoolCoreSize()

    • getWorkerPoolMaxSize

      public int getWorkerPoolMaxSize()

    • getSecondaryWorkerPoolMaxSize

      public int getSecondaryWorkerPoolMaxSize()

    • getWorkerThreadKeepaliveSec

      public int getWorkerThreadKeepaliveSec()

    • getSecondaryWorkerThreadKeepaliveSec

      public int getSecondaryWorkerThreadKeepaliveSec()

    • getWorkerPoolQueueLen

      public int getWorkerPoolQueueLen()

    • getSecondaryWorkerPoolQueueLen

      public int getSecondaryWorkerPoolQueueLen()

    • getIOThreadsPerReactor

      public int getIOThreadsPerReactor()

    • getIOBufferSize

      public int getIOBufferSize()

    • isKeepAliveDisabled

      public boolean isKeepAliveDisabled()

    • isCloseSocketOnEndpointTimeout

      public boolean isCloseSocketOnEndpointTimeout()

    • isTLSGracefulConnectionTerminationEnabled

      public boolean isTLSGracefulConnectionTerminationEnabled()

    • isConsumeAndDiscard

      public boolean isConsumeAndDiscard()

    • isConsumeAndDiscardBySecondaryWorkerPool

      public boolean isConsumeAndDiscardBySecondaryWorkerPool()

    • getMaxActiveConnections

      public int getMaxActiveConnections()

    • getListenerShutdownWaitTime

      public int getListenerShutdownWaitTime()

    • isPreserveUserAgentHeader

      public boolean isPreserveUserAgentHeader()

    • isPreserveServerHeader

      public boolean isPreserveServerHeader()

    • isForcedXmlMessageValidationEnabled

      public boolean isForcedXmlMessageValidationEnabled()

    • isForcedJSONMessageValidationEnabled

      public boolean isForcedJSONMessageValidationEnabled()

    • getPreserveHttpHeaders

      public String getPreserveHttpHeaders()

    • getResponsePreseveHttpHeaders

      public String getResponsePreseveHttpHeaders()

    • isDuplicateResponseContentTypeHeaderRemovalEnabled

      public boolean isDuplicateResponseContentTypeHeaderRemovalEnabled()

    • isServiceListBlocked

      public boolean isServiceListBlocked()

    • getConnectionIdleTime

      public int getConnectionIdleTime()

    • getMaximumConnectionLifespan

      public int getMaximumConnectionLifespan()

    • getConnectionGraceTime

      public int getConnectionGraceTime()

    • getCorrelationHeaderName

      public String getCorrelationHeaderName()

    • getCorrelationHeaderValidationPattern

      public Pattern getCorrelationHeaderValidationPattern()
      Returns the compiled pattern an incoming correlation header value must match, or null if validation is not configured or the configured regex is invalid.
      Returns:
      compiled correlation header validation pattern or null

    • isActivityIdHeaderRejectEnabled

      public boolean isActivityIdHeaderRejectEnabled()
      Returns whether requests with an activity ID header value that does not match the configured validation regex should be rejected. Defaults to false, in which case a new correlation ID is generated for such requests.
      Returns:
      true if the configured activity ID header validation action is "reject"

    • getExpectedMaxQueueingTime

      public String getExpectedMaxQueueingTime()

    • getExpectedMaxQueueingTimeForMessageDiscardWorker

      public Long getExpectedMaxQueueingTimeForMessageDiscardWorker()

    • getBooleanProperty

      public Boolean getBooleanProperty(String name)

    • getBooleanProperty

      public Boolean getBooleanProperty(String name, Boolean def)

    • getIntProperty

      public Integer getIntProperty(String name, Integer def)

    • getStringProperty

      public String getStringProperty(String name, String def)

    • getRESTDispatchService

      public String getRESTDispatchService()

    • getRestUriApiRegex

      public String getRestUriApiRegex()

    • getRestUriProxyRegex

      public String getRestUriProxyRegex()

    • isListeningIOReactorShared

      public boolean isListeningIOReactorShared()

    • getAllowedResponseProperties

      public String getAllowedResponseProperties()

    • isReverseProxyMode

      public boolean isReverseProxyMode()
      Check for reverse proxy mode
      Returns:
      whether reverse proxy mode is enabled

    • getPassThroughDefaultServiceName

      public String getPassThroughDefaultServiceName()
      Get the default synapse service name
      Returns:
      default synapse service name

    • isIgnoreCaseSensitiveHeaders

      public boolean isIgnoreCaseSensitiveHeaders()
      Get the value of the property to ignore case-sensitive headers from excess headers
      Returns:
      Value of the property