Class DefaultStreamCachingStrategy

  • All Implemented Interfaces:
    AutoCloseable, org.apache.camel.CamelContextAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.StreamCachingStrategy, org.apache.camel.StatefulService, org.apache.camel.StaticService, org.apache.camel.SuspendableService

    public class DefaultStreamCachingStrategy
    extends org.apache.camel.support.service.ServiceSupport
    implements org.apache.camel.CamelContextAware, org.apache.camel.spi.StreamCachingStrategy
    Default implementation of StreamCachingStrategy
    • Constructor Detail

      • DefaultStreamCachingStrategy

        public DefaultStreamCachingStrategy()
    • Method Detail

      • getCamelContext

        public org.apache.camel.CamelContext getCamelContext()
        Specified by:
        getCamelContext in interface org.apache.camel.CamelContextAware
      • setCamelContext

        public void setCamelContext​(org.apache.camel.CamelContext camelContext)
        Specified by:
        setCamelContext in interface org.apache.camel.CamelContextAware
      • isEnabled

        public boolean isEnabled()
        Specified by:
        isEnabled in interface org.apache.camel.spi.StreamCachingStrategy
      • setEnabled

        public void setEnabled​(boolean enabled)
        Specified by:
        setEnabled in interface org.apache.camel.spi.StreamCachingStrategy
      • setSpoolDirectory

        public void setSpoolDirectory​(String path)
        Specified by:
        setSpoolDirectory in interface org.apache.camel.spi.StreamCachingStrategy
      • setSpoolDirectory

        public void setSpoolDirectory​(File path)
        Specified by:
        setSpoolDirectory in interface org.apache.camel.spi.StreamCachingStrategy
      • getSpoolDirectory

        public File getSpoolDirectory()
        Specified by:
        getSpoolDirectory in interface org.apache.camel.spi.StreamCachingStrategy
      • getSpoolThreshold

        public long getSpoolThreshold()
        Specified by:
        getSpoolThreshold in interface org.apache.camel.spi.StreamCachingStrategy
      • getSpoolUsedHeapMemoryThreshold

        public int getSpoolUsedHeapMemoryThreshold()
        Specified by:
        getSpoolUsedHeapMemoryThreshold in interface org.apache.camel.spi.StreamCachingStrategy
      • setSpoolUsedHeapMemoryThreshold

        public void setSpoolUsedHeapMemoryThreshold​(int spoolHeapMemoryWatermarkThreshold)
        Specified by:
        setSpoolUsedHeapMemoryThreshold in interface org.apache.camel.spi.StreamCachingStrategy
      • getSpoolUsedHeapMemoryLimit

        public org.apache.camel.spi.StreamCachingStrategy.SpoolUsedHeapMemoryLimit getSpoolUsedHeapMemoryLimit()
        Specified by:
        getSpoolUsedHeapMemoryLimit in interface org.apache.camel.spi.StreamCachingStrategy
      • setSpoolUsedHeapMemoryLimit

        public void setSpoolUsedHeapMemoryLimit​(org.apache.camel.spi.StreamCachingStrategy.SpoolUsedHeapMemoryLimit spoolUsedHeapMemoryLimit)
        Specified by:
        setSpoolUsedHeapMemoryLimit in interface org.apache.camel.spi.StreamCachingStrategy
      • setSpoolThreshold

        public void setSpoolThreshold​(long spoolThreshold)
        Specified by:
        setSpoolThreshold in interface org.apache.camel.spi.StreamCachingStrategy
      • getSpoolCipher

        public String getSpoolCipher()
        Specified by:
        getSpoolCipher in interface org.apache.camel.spi.StreamCachingStrategy
      • setSpoolCipher

        public void setSpoolCipher​(String spoolCipher)
        Specified by:
        setSpoolCipher in interface org.apache.camel.spi.StreamCachingStrategy
      • getBufferSize

        public int getBufferSize()
        Specified by:
        getBufferSize in interface org.apache.camel.spi.StreamCachingStrategy
      • setBufferSize

        public void setBufferSize​(int bufferSize)
        Specified by:
        setBufferSize in interface org.apache.camel.spi.StreamCachingStrategy
      • isRemoveSpoolDirectoryWhenStopping

        public boolean isRemoveSpoolDirectoryWhenStopping()
        Specified by:
        isRemoveSpoolDirectoryWhenStopping in interface org.apache.camel.spi.StreamCachingStrategy
      • setRemoveSpoolDirectoryWhenStopping

        public void setRemoveSpoolDirectoryWhenStopping​(boolean removeSpoolDirectoryWhenStopping)
        Specified by:
        setRemoveSpoolDirectoryWhenStopping in interface org.apache.camel.spi.StreamCachingStrategy
      • isAnySpoolRules

        public boolean isAnySpoolRules()
        Specified by:
        isAnySpoolRules in interface org.apache.camel.spi.StreamCachingStrategy
      • setAnySpoolRules

        public void setAnySpoolRules​(boolean anySpoolTasks)
        Specified by:
        setAnySpoolRules in interface org.apache.camel.spi.StreamCachingStrategy
      • getStatistics

        public org.apache.camel.spi.StreamCachingStrategy.Statistics getStatistics()
        Specified by:
        getStatistics in interface org.apache.camel.spi.StreamCachingStrategy
      • shouldSpoolCache

        public boolean shouldSpoolCache​(long length)
        Specified by:
        shouldSpoolCache in interface org.apache.camel.spi.StreamCachingStrategy
      • addSpoolRule

        public void addSpoolRule​(org.apache.camel.spi.StreamCachingStrategy.SpoolRule rule)
        Specified by:
        addSpoolRule in interface org.apache.camel.spi.StreamCachingStrategy
      • cache

        public org.apache.camel.StreamCache cache​(org.apache.camel.Exchange exchange)
        Specified by:
        cache in interface org.apache.camel.spi.StreamCachingStrategy
      • resolveSpoolDirectory

        protected String resolveSpoolDirectory​(String path)
      • defaultManagementName

        protected String defaultManagementName​(String path)
      • customResolveManagementName

        protected String customResolveManagementName​(String pattern)
      • doStart

        protected void doStart()
                        throws Exception
        Overrides:
        doStart in class org.apache.camel.support.service.BaseService
        Throws:
        Exception
      • doStop

        protected void doStop()
                       throws Exception
        Overrides:
        doStop in class org.apache.camel.support.service.BaseService
        Throws:
        Exception