@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
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
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()
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
processor
- the given processorException
- can be thrownpublic AvroConfiguration getConfiguration()
Apache Camel