Package ddf.camel.component.catalog.ingest

Class PostIngestConsumer

java.lang.Object
org.apache.camel.support.service.BaseService
org.apache.camel.support.service.ServiceSupport
org.apache.camel.support.DefaultConsumer
ddf.camel.component.catalog.ingest.PostIngestConsumer
All Implemented Interfaces:
ddf.catalog.plugin.PostIngestPlugin, AutoCloseable, org.apache.camel.Consumer, org.apache.camel.EndpointAware, org.apache.camel.health.HealthCheckAware, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.RouteIdAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class PostIngestConsumer extends org.apache.camel.support.DefaultConsumer implements ddf.catalog.plugin.PostIngestPlugin
Camel Consumer Post Ingest plugin used to provide the responses passed to Post Ingest Plugins to camel routes.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    ACTION
     
    static final String
    CREATE
     
    static final String
    DELETE
     
    static final String
    UPDATE
     

    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
    PostIngestConsumer(CatalogEndpoint endpoint, org.apache.camel.Processor processor)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    doStart()
     
    protected void
    doStop()
     
    ddf.catalog.operation.CreateResponse
    process(ddf.catalog.operation.CreateResponse input)
     
    ddf.catalog.operation.DeleteResponse
    process(ddf.catalog.operation.DeleteResponse input)
     
    ddf.catalog.operation.UpdateResponse
    process(ddf.catalog.operation.UpdateResponse input)
     

    Methods inherited from class org.apache.camel.support.DefaultConsumer

    createExchange, createUoW, defaultConsumerCallback, doBuild, doInit, doneUoW, doShutdown, getAsyncProcessor, getEndpoint, getExceptionHandler, getHealthCheck, getProcessor, getRoute, getRouteId, handleException, handleException, handleException, releaseExchange, setExceptionHandler, setHealthCheck, setRoute, setRouteId, toString

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

    build, doFail, 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, 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

  • Field Details

  • Constructor Details

    • PostIngestConsumer

      public PostIngestConsumer(CatalogEndpoint endpoint, org.apache.camel.Processor processor)

  • Method Details

    • process

      public ddf.catalog.operation.CreateResponse process(ddf.catalog.operation.CreateResponse input) throws ddf.catalog.plugin.PluginExecutionException
      Specified by:
      process in interface ddf.catalog.plugin.PostIngestPlugin
      Throws:
      ddf.catalog.plugin.PluginExecutionException

    • process

      public ddf.catalog.operation.UpdateResponse process(ddf.catalog.operation.UpdateResponse input) throws ddf.catalog.plugin.PluginExecutionException
      Specified by:
      process in interface ddf.catalog.plugin.PostIngestPlugin
      Throws:
      ddf.catalog.plugin.PluginExecutionException

    • process

      public ddf.catalog.operation.DeleteResponse process(ddf.catalog.operation.DeleteResponse input) throws ddf.catalog.plugin.PluginExecutionException
      Specified by:
      process in interface ddf.catalog.plugin.PostIngestPlugin
      Throws:
      ddf.catalog.plugin.PluginExecutionException

    • doStop

      protected void doStop() throws Exception
      Overrides:
      doStop in class org.apache.camel.support.DefaultConsumer
      Throws:
      Exception

    • doStart

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