Class QueryResponseTransformerConsumer
java.lang.Object
org.apache.camel.support.service.BaseService
org.apache.camel.support.service.ServiceSupport
org.apache.camel.support.DefaultConsumer
ddf.camel.component.catalog.transformer.TransformerConsumer
ddf.camel.component.catalog.queryresponsetransformer.QueryResponseTransformerConsumer
- All Implemented Interfaces:
ddf.catalog.transform.QueryResponseTransformer,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 QueryResponseTransformerConsumer
extends TransformerConsumer
implements ddf.catalog.transform.QueryResponseTransformer
Consumer for the custom Camel CatalogComponent. This
would map to a Camel
route node with a URI like
invalid reference
Consumer
catalog:queryresponsetransformer- Author:
- 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
ConstructorsConstructorDescriptionQueryResponseTransformerConsumer(CatalogEndpoint endpoint, org.apache.camel.Processor processor) Constructs the consumer for the custom Camel CatalogComponent. -
Method Summary
Modifier and TypeMethodDescriptionddf.catalog.data.BinaryContenttransform(ddf.catalog.operation.SourceResponse upstreamResponse, Map<String, Serializable> arguments) Methods inherited from class ddf.camel.component.catalog.transformer.TransformerConsumer
doStart, doStop, transformMethods 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, toStringMethods 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, suspendMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.camel.Service
build, close, init, start, stopMethods inherited from interface org.apache.camel.ShutdownableService
shutdownMethods inherited from interface org.apache.camel.StatefulService
getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspendingMethods inherited from interface org.apache.camel.SuspendableService
isSuspended, resume, suspend
-
Constructor Details
-
QueryResponseTransformerConsumer
public QueryResponseTransformerConsumer(CatalogEndpoint endpoint, org.apache.camel.Processor processor) Constructs the consumer for the custom Camel CatalogComponent. ThisConsumerwould map to a Camelroute node with a URI like catalog:queryresponsetransformer- Parameters:
endpoint- the Camel endpoint that created this consumerprocessor-
-
-
Method Details
-
transform
public ddf.catalog.data.BinaryContent transform(ddf.catalog.operation.SourceResponse upstreamResponse, Map<String, Serializable> arguments) throws ddf.catalog.transform.CatalogTransformerException- Specified by:
transformin interfaceddf.catalog.transform.QueryResponseTransformer- Throws:
ddf.catalog.transform.CatalogTransformerException
-