Package org.apache.camel.component.google.secret.manager.vault

Class PubsubReloadTriggerTask

  • All Implemented Interfaces:
    AutoCloseable, Runnable, org.apache.camel.CamelContextAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
    @PeriodicTask("gcp-secret-refresh")
public class PubsubReloadTriggerTask
extends org.apache.camel.support.service.ServiceSupport
implements org.apache.camel.CamelContextAware, Runnable
    Period task which checks if Google secrets has been updated and can trigger Camel to be reloaded.

    • 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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void doShutdown()  
      protected void doStart()  
      org.apache.camel.CamelContext getCamelContext()  
      Instant getLastCheckTime()
      Last time this task checked GCP for updated secrets.
      Instant getLastReloadTime()
      Last time GCP secrets update triggered reload.
      Map<String,​Instant> getUpdates()
      A map of the updated secrets with the latest updated time.
      boolean isReloadEnabled()  
      protected boolean matchSecret​(String name)  
      void run()  
      void setCamelContext​(org.apache.camel.CamelContext camelContext)  
      void setReloadEnabled​(boolean reloadEnabled)
      Whether Camel should be reloaded on AWS secret updated
      String toString()  

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

        build, doBuild, doFail, doInit, doLifecycleChange, doResume, doStop, 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 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 Detail

      • PubsubReloadTriggerTask

        public PubsubReloadTriggerTask()

    • Method Detail

      • getCamelContext

        public org.apache.camel.CamelContext getCamelContext()
        Specified by:
        getCamelContext in interface org.apache.camel.CamelContextAware

      • setCamelContext

        public void setCamelContext​(org.apache.camel.CamelContext camelContext)
        Specified by:
        setCamelContext in interface org.apache.camel.CamelContextAware

      • isReloadEnabled

        public boolean isReloadEnabled()

      • setReloadEnabled

        public void setReloadEnabled​(boolean reloadEnabled)
        Whether Camel should be reloaded on AWS secret updated

      • getUpdates

        public Map<String,​Instant> getUpdates()
        A map of the updated secrets with the latest updated time.

      • getLastCheckTime

        public Instant getLastCheckTime()
        Last time this task checked GCP for updated secrets.

      • getLastReloadTime

        public Instant getLastReloadTime()
        Last time GCP secrets update triggered reload.

      • doStart

        protected void doStart()
                throws Exception
        Overrides:
        doStart in class org.apache.camel.support.service.BaseService
        Throws:
        Exception

      • doShutdown

        protected void doShutdown()
                   throws Exception
        Overrides:
        doShutdown in class org.apache.camel.support.service.BaseService
        Throws:
        Exception

      • run

        public void run()
        Specified by:
        run in interface Runnable

      • matchSecret

        protected boolean matchSecret​(String name)