Package ddf.camel.component.catalog

Class CatalogEndpoint

java.lang.Object
org.apache.camel.support.service.BaseService
org.apache.camel.support.service.ServiceSupport
org.apache.camel.support.DefaultEndpoint
ddf.camel.component.catalog.CatalogEndpoint
All Implemented Interfaces:
AutoCloseable, org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class CatalogEndpoint extends org.apache.camel.support.DefaultEndpoint implements org.apache.camel.MultipleConsumersSupport
Represents a Camel endpoint for the custom catalog Camel route node.
Author:
Hugh Rodgers, William Miller

  • 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
    CatalogEndpoint(String uri, CatalogComponent component, String transformerId, String mimeType, String contextPath, ddf.catalog.CatalogFramework catalogFramework, ddf.mime.MimeTypeMapper mimeTypeMapper)
    Constructs a CatalogEndpoint for the specified custom catalog component.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.camel.Consumer
    createConsumer(org.apache.camel.Processor processor)
     
    org.apache.camel.Producer
    createProducer()
     
    boolean
    equals(Object o)
     
    CatalogComponent
    getComponent()
     
    String
    getContextPath()
     
    org.apache.camel.ExchangePattern
    getExchangePattern()
     
    ExecutorService
    getExecutor()
     
    String
    getMimeType()
     
    ddf.mime.MimeTypeMapper
    getMimeTypeMapper()
     
    String
    getTransformerId()
     
    int
    hashCode()
     
    boolean
    isMultipleConsumersSupported()
     
    boolean
    isSingleton()
     
    boolean
    isSynchronous()
     
    void
    setExecutor(ExecutorService executor)
     
    void
    setSynchronous(boolean synchronous)
     

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

    configureConsumer, configureExchange, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStart, doStop, getCamelContext, getEndpointKey, getEndpointUri, getExceptionHandler, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isPollingConsumerCopy, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerCopy, setPollingConsumerQueueSize, setProperties, toString

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

    build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, 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, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface org.apache.camel.Endpoint

    getEndpointBaseUri, isSingletonProducer

    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

    • CatalogEndpoint

      public CatalogEndpoint(String uri, CatalogComponent component, String transformerId, String mimeType, String contextPath, ddf.catalog.CatalogFramework catalogFramework, ddf.mime.MimeTypeMapper mimeTypeMapper)
      Constructs a CatalogEndpoint for the specified custom catalog component.
      Parameters:
      uri - the endpoint's URI
      component - the route node catalog component
      transformerId - the InputTransformer ID, id=xml
      mimeType - the registered service mime-type
      contextPath - the context path of the catalog route node, which is the portion of the URI after the catalog scheme, e.g., inputtransformer, which indicates how to interpret the catalog route node
      catalogFramework - the catalog framework

  • Method Details

    • getComponent

      public CatalogComponent getComponent()
      Overrides:
      getComponent in class org.apache.camel.support.DefaultEndpoint

    • getExchangePattern

      public org.apache.camel.ExchangePattern getExchangePattern()
      Specified by:
      getExchangePattern in interface org.apache.camel.Endpoint
      Overrides:
      getExchangePattern in class org.apache.camel.support.DefaultEndpoint

    • createProducer

      public org.apache.camel.Producer createProducer()
      Specified by:
      createProducer in interface org.apache.camel.Endpoint

    • createConsumer

      public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
      Specified by:
      createConsumer in interface org.apache.camel.Endpoint

    • getTransformerId

      public String getTransformerId()
      Returns:
      ID of the transformer specified as a parameter in the Camel route node

    • getMimeType

      public String getMimeType()

    • getMimeTypeMapper

      public ddf.mime.MimeTypeMapper getMimeTypeMapper()

    • getContextPath

      public String getContextPath()

    • isSingleton

      public boolean isSingleton()
      Specified by:
      isSingleton in interface org.apache.camel.IsSingleton
      Overrides:
      isSingleton in class org.apache.camel.support.DefaultEndpoint

    • isMultipleConsumersSupported

      public boolean isMultipleConsumersSupported()
      Specified by:
      isMultipleConsumersSupported in interface org.apache.camel.MultipleConsumersSupport

    • setExecutor

      public void setExecutor(ExecutorService executor)

    • getExecutor

      public ExecutorService getExecutor()

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class org.apache.camel.support.DefaultEndpoint

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class org.apache.camel.support.DefaultEndpoint

    • isSynchronous

      public boolean isSynchronous()

    • setSynchronous

      public void setSynchronous(boolean synchronous)