ddf.camel.component.catalog.inputtransformer

Class InputTransformerConsumer

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultConsumer

ddf.camel.component.catalog.transformer.TransformerConsumer

ddf.camel.component.catalog.inputtransformer.InputTransformerConsumer

All Implemented Interfaces:

InputTransformer, org.apache.camel.Consumer, org.apache.camel.EndpointAware, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class InputTransformerConsumer
extends TransformerConsumer
implements InputTransformer

Consumer for the custom Camel CatalogComponent. This Consumer would map to a Camel route node with a URI like catalog:inputtransformer

Author:

Hugh Rodgers, Lockheed Martin, William Miller, Lockheed Martin, ddf.isgs@lmco.com

Field Summary

Fields inherited from class org.apache.camel.impl.DefaultConsumer

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
InputTransformerConsumer(CatalogEndpoint endpoint, org.apache.camel.Processor processor) Constructs the consumer for the custom Camel CatalogComponent.

Method Summary

Modifier and Type	Method and Description
Metacard	transform(InputStream input) Transforms the input into a Metacard.
Metacard	transform(InputStream input, String id) Transforms the input into a Metacard and associates the id with the Metacard on creation.

Methods inherited from class ddf.camel.component.catalog.transformer.TransformerConsumer

doStart, doStop, transform

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

createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString

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

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, 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

start, stop

Constructor Detail

InputTransformerConsumer

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

Constructs the consumer for the custom Camel CatalogComponent. This Consumer would map to a Camel route node with a URI like catalog:inputtransformer

Parameters:

endpoint - the Camel endpoint that created this consumer

processor -

Method Detail

transform

public Metacard transform(InputStream input)
                   throws IOException,
                          CatalogTransformerException

Description copied from interface: InputTransformer

Transforms the input into a Metacard.

Specified by:

transform in interface InputTransformer

Parameters:

input - the binary InputStream to transform

Returns:

the generated Metacard

Throws:

IOException - if an I/O exception occurs when reading the InputStream

CatalogTransformerException - if an error occurs during transformation

transform

public Metacard transform(InputStream input,
                          String id)
                   throws IOException,
                          CatalogTransformerException

Description copied from interface: InputTransformer

Transforms the input into a Metacard and associates the id with the Metacard on creation.

Specified by:

transform in interface InputTransformer

Parameters:

input - the binary InputStream to transform

id - the attribute value for the Metacard.ID attribute that should be set in the generated Metacard

Returns:

the generated Metacard

Throws:

IOException - if an I/O exception occurs when reading the InputStream

CatalogTransformerException - if an error occurs during transformation