Package org.apache.camel.impl.engine
Class DefaultStreamCachingStrategy
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.impl.engine.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 ofStreamCachingStrategy
-
-
Constructor Summary
Constructors Constructor Description DefaultStreamCachingStrategy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addSpoolRule(org.apache.camel.spi.StreamCachingStrategy.SpoolRule rule)
org.apache.camel.StreamCache
cache(org.apache.camel.Exchange exchange)
protected String
customResolveManagementName(String pattern)
protected String
defaultManagementName(String path)
protected void
doStart()
protected void
doStop()
int
getBufferSize()
org.apache.camel.CamelContext
getCamelContext()
String
getSpoolCipher()
File
getSpoolDirectory()
long
getSpoolThreshold()
org.apache.camel.spi.StreamCachingStrategy.SpoolUsedHeapMemoryLimit
getSpoolUsedHeapMemoryLimit()
int
getSpoolUsedHeapMemoryThreshold()
org.apache.camel.spi.StreamCachingStrategy.Statistics
getStatistics()
boolean
isAnySpoolRules()
boolean
isEnabled()
boolean
isRemoveSpoolDirectoryWhenStopping()
protected String
resolveSpoolDirectory(String path)
void
setAnySpoolRules(boolean anySpoolTasks)
void
setBufferSize(int bufferSize)
void
setCamelContext(org.apache.camel.CamelContext camelContext)
void
setEnabled(boolean enabled)
void
setRemoveSpoolDirectoryWhenStopping(boolean removeSpoolDirectoryWhenStopping)
void
setSpoolCipher(String spoolCipher)
void
setSpoolDirectory(File path)
void
setSpoolDirectory(String path)
void
setSpoolThreshold(long spoolThreshold)
void
setSpoolUsedHeapMemoryLimit(org.apache.camel.spi.StreamCachingStrategy.SpoolUsedHeapMemoryLimit spoolUsedHeapMemoryLimit)
void
setSpoolUsedHeapMemoryThreshold(int spoolHeapMemoryWatermarkThreshold)
boolean
shouldSpoolCache(long length)
String
toString()
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Method Detail
-
getCamelContext
public org.apache.camel.CamelContext getCamelContext()
- Specified by:
getCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
setCamelContext
public void setCamelContext(org.apache.camel.CamelContext camelContext)
- Specified by:
setCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
isEnabled
public boolean isEnabled()
- Specified by:
isEnabled
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setEnabled
public void setEnabled(boolean enabled)
- Specified by:
setEnabled
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setSpoolDirectory
public void setSpoolDirectory(String path)
- Specified by:
setSpoolDirectory
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setSpoolDirectory
public void setSpoolDirectory(File path)
- Specified by:
setSpoolDirectory
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
getSpoolDirectory
public File getSpoolDirectory()
- Specified by:
getSpoolDirectory
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
getSpoolThreshold
public long getSpoolThreshold()
- Specified by:
getSpoolThreshold
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
getSpoolUsedHeapMemoryThreshold
public int getSpoolUsedHeapMemoryThreshold()
- Specified by:
getSpoolUsedHeapMemoryThreshold
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setSpoolUsedHeapMemoryThreshold
public void setSpoolUsedHeapMemoryThreshold(int spoolHeapMemoryWatermarkThreshold)
- Specified by:
setSpoolUsedHeapMemoryThreshold
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
getSpoolUsedHeapMemoryLimit
public org.apache.camel.spi.StreamCachingStrategy.SpoolUsedHeapMemoryLimit getSpoolUsedHeapMemoryLimit()
- Specified by:
getSpoolUsedHeapMemoryLimit
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setSpoolUsedHeapMemoryLimit
public void setSpoolUsedHeapMemoryLimit(org.apache.camel.spi.StreamCachingStrategy.SpoolUsedHeapMemoryLimit spoolUsedHeapMemoryLimit)
- Specified by:
setSpoolUsedHeapMemoryLimit
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setSpoolThreshold
public void setSpoolThreshold(long spoolThreshold)
- Specified by:
setSpoolThreshold
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
getSpoolCipher
public String getSpoolCipher()
- Specified by:
getSpoolCipher
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setSpoolCipher
public void setSpoolCipher(String spoolCipher)
- Specified by:
setSpoolCipher
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
getBufferSize
public int getBufferSize()
- Specified by:
getBufferSize
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setBufferSize
public void setBufferSize(int bufferSize)
- Specified by:
setBufferSize
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
isRemoveSpoolDirectoryWhenStopping
public boolean isRemoveSpoolDirectoryWhenStopping()
- Specified by:
isRemoveSpoolDirectoryWhenStopping
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setRemoveSpoolDirectoryWhenStopping
public void setRemoveSpoolDirectoryWhenStopping(boolean removeSpoolDirectoryWhenStopping)
- Specified by:
setRemoveSpoolDirectoryWhenStopping
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
isAnySpoolRules
public boolean isAnySpoolRules()
- Specified by:
isAnySpoolRules
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
setAnySpoolRules
public void setAnySpoolRules(boolean anySpoolTasks)
- Specified by:
setAnySpoolRules
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
getStatistics
public org.apache.camel.spi.StreamCachingStrategy.Statistics getStatistics()
- Specified by:
getStatistics
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
shouldSpoolCache
public boolean shouldSpoolCache(long length)
- Specified by:
shouldSpoolCache
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
addSpoolRule
public void addSpoolRule(org.apache.camel.spi.StreamCachingStrategy.SpoolRule rule)
- Specified by:
addSpoolRule
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
cache
public org.apache.camel.StreamCache cache(org.apache.camel.Exchange exchange)
- Specified by:
cache
in interfaceorg.apache.camel.spi.StreamCachingStrategy
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
-