Package org.apache.camel.component.etcd3.processor.aggregate

Class Etcd3AggregationRepository

java.lang.Object
org.apache.camel.support.service.BaseService
org.apache.camel.support.service.ServiceSupport
org.apache.camel.component.etcd3.processor.aggregate.Etcd3AggregationRepository
All Implemented Interfaces:
AutoCloseable, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.AggregationRepository, org.apache.camel.spi.OptimisticLockingAggregationRepository, org.apache.camel.spi.RecoverableAggregationRepository, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
@Metadata(label="bean", description="Aggregation repository that uses Etcd3 to store exchanges.", annotations="interfaceName=org.apache.camel.spi.AggregationRepository") @Configurer(metadataOnly=true) @Deprecated(since="4.9.0", forRemoval=true) public class Etcd3AggregationRepository extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.spi.RecoverableAggregationRepository, org.apache.camel.spi.OptimisticLockingAggregationRepository
Deprecated, for removal: This API element is subject to removal in a future version.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.camel.spi.OptimisticLockingAggregationRepository

    org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException

  • Field Summary

    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
    Etcd3AggregationRepository()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    Etcd3AggregationRepository(String prefixName, String endpoint)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    Etcd3AggregationRepository(String prefixName, String endpoint, boolean optimistic)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    Etcd3AggregationRepository(String prefixName, String persistencePrefixName, String endpoint)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    Etcd3AggregationRepository(String repositoryName, String persistentRepositoryName, String endpoint, boolean optimistic)
    Deprecated, for removal: This API element is subject to removal in a future version.
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.camel.Exchange
    add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    org.apache.camel.Exchange
    add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange oldExchange, org.apache.camel.Exchange newExchange)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    protected void
    doInit()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    protected void
    doStart()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    protected void
    doStop()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    org.apache.camel.Exchange
    get(org.apache.camel.CamelContext camelContext, String key)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    io.etcd.jetcd.Client
    getClient()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    String
    getDeadLetterUri()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    String
    getEndpoint()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    Set<String>
    getKeys()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    int
    getMaximumRedeliveries()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    String
    getPrefixName()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    long
    getRecoveryInterval()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    boolean
    isAllowSerializedHeaders()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    boolean
    isOptimistic()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    boolean
    isUseRecovery()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    org.apache.camel.Exchange
    recover(org.apache.camel.CamelContext camelContext, String exchangeId)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    remove(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    Set<String>
    scan(org.apache.camel.CamelContext camelContext)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setAllowSerializedHeaders(boolean allowSerializedHeaders)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setClient(io.etcd.jetcd.Client client)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setDeadLetterUri(String deadLetterUri)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setEndpoint(String endpoint)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setMaximumRedeliveries(int maximumRedeliveries)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setOptimistic(boolean optimistic)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setPrefixName(String prefixName)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setRecoveryInterval(long interval)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setRecoveryInterval(long interval, TimeUnit timeUnit)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setUseRecovery(boolean useRecovery)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    protected org.apache.camel.Exchange
    unmarshallExchange(org.apache.camel.CamelContext camelContext, org.apache.camel.support.DefaultExchangeHolder holder)
    Deprecated, for removal: This API element is subject to removal in a future version.
     

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

    build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, 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 java.lang.Object

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

    Methods inherited from interface org.apache.camel.spi.RecoverableAggregationRepository

    confirmWithResult, getRecoveryIntervalInMillis

    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

    • Etcd3AggregationRepository

      public Etcd3AggregationRepository()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • Etcd3AggregationRepository

      public Etcd3AggregationRepository(String prefixName, String endpoint)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • Etcd3AggregationRepository

      public Etcd3AggregationRepository(String prefixName, String persistencePrefixName, String endpoint)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • Etcd3AggregationRepository

      public Etcd3AggregationRepository(String prefixName, String endpoint, boolean optimistic)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • Etcd3AggregationRepository

      public Etcd3AggregationRepository(String repositoryName, String persistentRepositoryName, String endpoint, boolean optimistic)
      Deprecated, for removal: This API element is subject to removal in a future version.

  • Method Details

    • add

      public org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange oldExchange, org.apache.camel.Exchange newExchange) throws org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      add in interface org.apache.camel.spi.OptimisticLockingAggregationRepository
      Throws:
      org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException

    • add

      public org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      add in interface org.apache.camel.spi.AggregationRepository

    • scan

      public Set<String> scan(org.apache.camel.CamelContext camelContext)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      scan in interface org.apache.camel.spi.RecoverableAggregationRepository

    • recover

      public org.apache.camel.Exchange recover(org.apache.camel.CamelContext camelContext, String exchangeId)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      recover in interface org.apache.camel.spi.RecoverableAggregationRepository

    • setRecoveryInterval

      public void setRecoveryInterval(long interval, TimeUnit timeUnit)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      setRecoveryInterval in interface org.apache.camel.spi.RecoverableAggregationRepository

    • getRecoveryInterval

      public long getRecoveryInterval()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      getRecoveryInterval in interface org.apache.camel.spi.RecoverableAggregationRepository

    • setRecoveryInterval

      public void setRecoveryInterval(long interval)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      setRecoveryInterval in interface org.apache.camel.spi.RecoverableAggregationRepository

    • setUseRecovery

      public void setUseRecovery(boolean useRecovery)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      setUseRecovery in interface org.apache.camel.spi.RecoverableAggregationRepository

    • isUseRecovery

      public boolean isUseRecovery()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      isUseRecovery in interface org.apache.camel.spi.RecoverableAggregationRepository

    • setDeadLetterUri

      public void setDeadLetterUri(String deadLetterUri)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      setDeadLetterUri in interface org.apache.camel.spi.RecoverableAggregationRepository

    • getDeadLetterUri

      public String getDeadLetterUri()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      getDeadLetterUri in interface org.apache.camel.spi.RecoverableAggregationRepository

    • setMaximumRedeliveries

      public void setMaximumRedeliveries(int maximumRedeliveries)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      setMaximumRedeliveries in interface org.apache.camel.spi.RecoverableAggregationRepository

    • getMaximumRedeliveries

      public int getMaximumRedeliveries()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      getMaximumRedeliveries in interface org.apache.camel.spi.RecoverableAggregationRepository

    • isAllowSerializedHeaders

      public boolean isAllowSerializedHeaders()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • setAllowSerializedHeaders

      public void setAllowSerializedHeaders(boolean allowSerializedHeaders)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • isOptimistic

      public boolean isOptimistic()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • setOptimistic

      public void setOptimistic(boolean optimistic)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • getEndpoint

      public String getEndpoint()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • setEndpoint

      public void setEndpoint(String endpoint)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • getClient

      public io.etcd.jetcd.Client getClient()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • setClient

      public void setClient(io.etcd.jetcd.Client client)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • getPrefixName

      public String getPrefixName()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • setPrefixName

      public void setPrefixName(String prefixName)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • get

      public org.apache.camel.Exchange get(org.apache.camel.CamelContext camelContext, String key)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      get in interface org.apache.camel.spi.AggregationRepository

    • remove

      public void remove(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      remove in interface org.apache.camel.spi.AggregationRepository
      Specified by:
      remove in interface org.apache.camel.spi.OptimisticLockingAggregationRepository

    • confirm

      public void confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      confirm in interface org.apache.camel.spi.AggregationRepository

    • getKeys

      public Set<String> getKeys()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      getKeys in interface org.apache.camel.spi.AggregationRepository

    • doInit

      protected void doInit() throws Exception
      Deprecated, for removal: This API element is subject to removal in a future version.
      Overrides:
      doInit in class org.apache.camel.support.service.BaseService
      Throws:
      Exception

    • doStart

      protected void doStart()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Overrides:
      doStart in class org.apache.camel.support.service.BaseService

    • doStop

      protected void doStop() throws Exception
      Deprecated, for removal: This API element is subject to removal in a future version.
      Overrides:
      doStop in class org.apache.camel.support.service.BaseService
      Throws:
      Exception

    • unmarshallExchange

      protected org.apache.camel.Exchange unmarshallExchange(org.apache.camel.CamelContext camelContext, org.apache.camel.support.DefaultExchangeHolder holder)
      Deprecated, for removal: This API element is subject to removal in a future version.