Class EmptyConsumerCache

java.lang.Object

org.apache.camel.support.service.BaseService

org.apache.camel.support.service.ServiceSupport

org.apache.camel.support.cache.DefaultConsumerCache

org.apache.camel.support.cache.EmptyConsumerCache

All Implemented Interfaces:

AutoCloseable, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.ConsumerCache, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class EmptyConsumerCache
extends DefaultConsumerCache

A ConsumerCache that does not cache PollingConsumers but instead creates a new consumer on every acquirePollingConsumer(Endpoint) and stops and shuts it down on releasePollingConsumer(Endpoint, PollingConsumer).

Since:

4.21

Field Summary

Fields inherited from class DefaultConsumerCache

CONTEXT_IS_STOPPED

Fields inherited from class org.apache.camel.support.service.BaseService

BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING

Constructor Summary

Constructors

Constructor	Description
EmptyConsumerCache(Object source, org.apache.camel.CamelContext camelContext)

Method Summary

Modifier and Type	Method	Description
org.apache.camel.PollingConsumer	acquirePollingConsumer(org.apache.camel.Endpoint endpoint)	Acquires a pooled PollingConsumer which you must release back again after usage using the DefaultConsumerCache.releasePollingConsumer(org.apache.camel.Endpoint, org.apache.camel.PollingConsumer) method.
int	getCapacity()	Gets the maximum cache size (capacity).
void	releasePollingConsumer(org.apache.camel.Endpoint endpoint, org.apache.camel.PollingConsumer pollingConsumer)	Releases an acquired producer back after usage.
String	toString()

Methods inherited from class DefaultConsumerCache

cleanUp, createServicePool, doBuild, doInit, doShutdown, doStart, doStop, getCamelContext, getEndpointUtilizationStatistics, getSource, isExtendedStatistics, purge, receive, receive, receiveNoWait, setExtendedStatistics, size

Methods inherited from class org.apache.camel.support.service.BaseService

build, doFail, doLifecycleChange, doResume, doSuspend, fail, getInternalLock, 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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

build, close, init, start, stop

Methods inherited from interface org.apache.camel.ShutdownableService

shutdown

Methods inherited from interface org.apache.camel.StatefulService

getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending

Methods inherited from interface org.apache.camel.SuspendableService

isSuspended, resume, suspend

Constructor Details

EmptyConsumerCache

public EmptyConsumerCache(Object source,
 org.apache.camel.CamelContext camelContext)

Method Details

acquirePollingConsumer

public org.apache.camel.PollingConsumer acquirePollingConsumer(org.apache.camel.Endpoint endpoint)

Description copied from class: DefaultConsumerCache

Acquires a pooled PollingConsumer which you must release back again after usage using the DefaultConsumerCache.releasePollingConsumer(org.apache.camel.Endpoint, org.apache.camel.PollingConsumer) method.

Specified by:

acquirePollingConsumer in interface org.apache.camel.spi.ConsumerCache

Overrides:

acquirePollingConsumer in class DefaultConsumerCache

Parameters:

endpoint - the endpoint

Returns:

the PollingConsumer

releasePollingConsumer

public void releasePollingConsumer(org.apache.camel.Endpoint endpoint,
 org.apache.camel.PollingConsumer pollingConsumer)

Description copied from class: DefaultConsumerCache

Releases an acquired producer back after usage.

Specified by:

releasePollingConsumer in interface org.apache.camel.spi.ConsumerCache

Overrides:

releasePollingConsumer in class DefaultConsumerCache

Parameters:

endpoint - the endpoint

pollingConsumer - the pollingConsumer to release

getCapacity

public int getCapacity()

Description copied from class: DefaultConsumerCache

Gets the maximum cache size (capacity).

Specified by:

getCapacity in interface org.apache.camel.spi.ConsumerCache

Overrides:

getCapacity in class DefaultConsumerCache

Returns:

the capacity

toString

public String toString()

Overrides:

toString in class DefaultConsumerCache