public class AvroNettyEndpoint extends AvroEndpoint
Constructor and Description |
---|
AvroNettyEndpoint(String endpointUri,
org.apache.camel.Component component,
AvroConfiguration configuration)
Constructs a fully-initialized DefaultEndpoint instance.
|
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
createConsumer, createExchange, getConfiguration, 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 AvroNettyEndpoint(String endpointUri, org.apache.camel.Component component, AvroConfiguration configuration)
endpointUri
- the full URI used to create this endpointcomponent
- the component that created this endpointApache Camel