@UriEndpoint(scheme="avro", title="Avro", syntax="avro:transport:host:port/messageName", consumerClass=AvroConsumer.class, label="messaging,transformation") public abstract class AvroEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.AsyncEndpoint
Constructor and Description |
---|
AvroEndpoint(String endpointUri,
org.apache.camel.Component component,
AvroConfiguration configuration)
Constructs a fully-initialized DefaultEndpoint instance.
|
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
org.apache.camel.Exchange |
createExchange(org.apache.avro.Protocol.Message message,
Object request) |
AvroConfiguration |
getConfiguration() |
boolean |
isSingleton() |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public AvroEndpoint(String endpointUri, org.apache.camel.Component component, AvroConfiguration configuration)
endpointUri
- the full URI used to create this endpointcomponent
- the component that created this endpointpublic org.apache.camel.Exchange createExchange(org.apache.avro.Protocol.Message message, Object request)
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
processor
- the given processorException
- can be thrownpublic AvroConfiguration getConfiguration()
Apache Camel