Package org.apache.camel.impl.engine
Class PooledExchangeFactory
- 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.PrototypeExchangeFactory
-
- org.apache.camel.impl.engine.PooledExchangeFactory
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.NonManagedService
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.ExchangeFactory
,org.apache.camel.spi.PooledObjectFactory<org.apache.camel.Exchange>
,org.apache.camel.spi.RouteIdAware
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public final class PooledExchangeFactory extends PrototypeExchangeFactory
PooledExchangeFactory
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 PooledExchangeFactory()
PooledExchangeFactory(org.apache.camel.Consumer consumer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.Exchange
create(boolean autoRelease)
org.apache.camel.Exchange
create(org.apache.camel.Endpoint fromEndpoint, boolean autoRelease)
protected org.apache.camel.PooledExchange
createPooledExchange(org.apache.camel.Endpoint fromEndpoint, boolean autoRelease)
protected void
doBuild()
protected void
doStop()
boolean
isPooled()
org.apache.camel.spi.ExchangeFactory
newExchangeFactory(org.apache.camel.Consumer consumer)
boolean
release(org.apache.camel.Exchange exchange)
-
Methods inherited from class org.apache.camel.impl.engine.PrototypeExchangeFactory
acquire, doStart, getConsumer, getRouteId, setRouteId
-
Methods inherited from class org.apache.camel.support.PooledObjectFactorySupport
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, 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
-
doBuild
protected void doBuild() throws Exception
- Overrides:
doBuild
in classPrototypeExchangeFactory
- Throws:
Exception
-
newExchangeFactory
public org.apache.camel.spi.ExchangeFactory newExchangeFactory(org.apache.camel.Consumer consumer)
- Specified by:
newExchangeFactory
in interfaceorg.apache.camel.spi.ExchangeFactory
- Overrides:
newExchangeFactory
in classPrototypeExchangeFactory
-
create
public org.apache.camel.Exchange create(boolean autoRelease)
- Specified by:
create
in interfaceorg.apache.camel.spi.ExchangeFactory
- Overrides:
create
in classPrototypeExchangeFactory
-
create
public org.apache.camel.Exchange create(org.apache.camel.Endpoint fromEndpoint, boolean autoRelease)
- Specified by:
create
in interfaceorg.apache.camel.spi.ExchangeFactory
- Overrides:
create
in classPrototypeExchangeFactory
-
release
public boolean release(org.apache.camel.Exchange exchange)
- Specified by:
release
in interfaceorg.apache.camel.spi.ExchangeFactory
- Specified by:
release
in interfaceorg.apache.camel.spi.PooledObjectFactory<org.apache.camel.Exchange>
- Overrides:
release
in classPrototypeExchangeFactory
-
createPooledExchange
protected org.apache.camel.PooledExchange createPooledExchange(org.apache.camel.Endpoint fromEndpoint, boolean autoRelease)
-
isPooled
public boolean isPooled()
- Specified by:
isPooled
in interfaceorg.apache.camel.spi.PooledObjectFactory<org.apache.camel.Exchange>
- Overrides:
isPooled
in classPrototypeExchangeFactory
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classPrototypeExchangeFactory
- Throws:
Exception
-
-