Package org.apache.camel.impl.engine
Class PooledProcessorExchangeFactory
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.PooledObjectFactorySupport<org.apache.camel.Exchange>
-
- org.apache.camel.impl.engine.PrototypeProcessorExchangeFactory
-
- org.apache.camel.impl.engine.PooledProcessorExchangeFactory
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.NonManagedService
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.HasId
,org.apache.camel.spi.IdAware
,org.apache.camel.spi.PooledObjectFactory<org.apache.camel.Exchange>
,org.apache.camel.spi.ProcessorExchangeFactory
,org.apache.camel.spi.RouteIdAware
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class PooledProcessorExchangeFactory extends PrototypeProcessorExchangeFactory
PooledProcessorExchangeFactory
that reusesExchange
instance from a pool.
-
-
Field Summary
-
Fields inherited from class org.apache.camel.support.PooledObjectFactorySupport
camelContext, capacity, pool, source, statistics, statisticsEnabled
-
-
Constructor Summary
Constructors Constructor Description PooledProcessorExchangeFactory()
PooledProcessorExchangeFactory(org.apache.camel.Processor processor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.Exchange
create(org.apache.camel.Endpoint fromEndpoint, org.apache.camel.ExchangePattern exchangePattern)
org.apache.camel.Exchange
createCopy(org.apache.camel.Exchange exchange)
org.apache.camel.Exchange
createCorrelatedCopy(org.apache.camel.Exchange exchange, boolean handover)
boolean
isPooled()
org.apache.camel.spi.ProcessorExchangeFactory
newProcessorExchangeFactory(org.apache.camel.Processor processor)
boolean
release(org.apache.camel.Exchange exchange)
-
Methods inherited from class org.apache.camel.impl.engine.PrototypeProcessorExchangeFactory
acquire, doStop, getId, getProcessor, getRouteId, setId, setRouteId
-
Methods inherited from class org.apache.camel.support.PooledObjectFactorySupport
doBuild, doShutdown, getCamelContext, getCapacity, getSize, getStatistics, isStatisticsEnabled, purge, resetStatistics, setCamelContext, setCapacity, setStatisticsEnabled
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doFail, doInit, doLifecycleChange, doResume, doStart, 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, toString, wait, wait, wait
-
Methods inherited from interface org.apache.camel.CamelContextAware
getCamelContext, setCamelContext
-
Methods inherited from interface org.apache.camel.spi.PooledObjectFactory
getCapacity, getSize, getStatistics, isStatisticsEnabled, purge, resetStatistics, setCapacity, setStatisticsEnabled
-
-
-
-
Method Detail
-
isPooled
public boolean isPooled()
- Specified by:
isPooled
in interfaceorg.apache.camel.spi.PooledObjectFactory<org.apache.camel.Exchange>
- Overrides:
isPooled
in classPrototypeProcessorExchangeFactory
-
newProcessorExchangeFactory
public org.apache.camel.spi.ProcessorExchangeFactory newProcessorExchangeFactory(org.apache.camel.Processor processor)
- Specified by:
newProcessorExchangeFactory
in interfaceorg.apache.camel.spi.ProcessorExchangeFactory
- Overrides:
newProcessorExchangeFactory
in classPrototypeProcessorExchangeFactory
-
createCopy
public org.apache.camel.Exchange createCopy(org.apache.camel.Exchange exchange)
- Specified by:
createCopy
in interfaceorg.apache.camel.spi.ProcessorExchangeFactory
- Overrides:
createCopy
in classPrototypeProcessorExchangeFactory
-
createCorrelatedCopy
public org.apache.camel.Exchange createCorrelatedCopy(org.apache.camel.Exchange exchange, boolean handover)
- Specified by:
createCorrelatedCopy
in interfaceorg.apache.camel.spi.ProcessorExchangeFactory
- Overrides:
createCorrelatedCopy
in classPrototypeProcessorExchangeFactory
-
create
public org.apache.camel.Exchange create(org.apache.camel.Endpoint fromEndpoint, org.apache.camel.ExchangePattern exchangePattern)
- Specified by:
create
in interfaceorg.apache.camel.spi.ProcessorExchangeFactory
- Overrides:
create
in classPrototypeProcessorExchangeFactory
-
release
public boolean release(org.apache.camel.Exchange exchange)
- Specified by:
release
in interfaceorg.apache.camel.spi.PooledObjectFactory<org.apache.camel.Exchange>
- Specified by:
release
in interfaceorg.apache.camel.spi.ProcessorExchangeFactory
- Overrides:
release
in classPrototypeProcessorExchangeFactory
-
-