public class UimaAsProducer
extends org.apache.camel.impl.DefaultProducer
implements org.apache.camel.AsyncProcessor
UimaAsProducer
sends the body of a message to a UIMA AS processing
pipeline.
Configuration URI:
uimadriver:authority?queue="nameofqueue"
For example:
uimadriver:tcp://localhost:61616?queue=TextAnalysisQueueConstructor and Description |
---|
UimaAsProducer(String brokerAddress,
String queue,
Integer casPoolSize,
Integer timeout,
org.apache.camel.Endpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
process(org.apache.camel.Exchange exchange)
Not implemented, since the producer implements the AsyncProcessor interface.
|
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public void process(org.apache.camel.Exchange exchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
process
in interface org.apache.camel.AsyncProcessor
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.