Package org.apache.camel.component.avro
Class AvroComponent
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultComponent
-
- org.apache.camel.component.avro.AvroComponent
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Component
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
@Component("avro") public class AvroComponent extends org.apache.camel.support.DefaultComponent
-
-
Constructor Summary
Constructors Constructor Description AvroComponent()
AvroComponent(org.apache.camel.CamelContext context)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.camel.Endpoint
createEndpoint(String uri, String remaining, Map<String,Object> parameters)
A factory method allowing derived components to create a new endpoint from the given URI, remaining path and optional parametersAvroConfiguration
getConfiguration()
void
register(String uri, String messageName, AvroConsumer consumer)
Registers new responder with uri as key.void
setConfiguration(AvroConfiguration configuration)
To use a sharedAvroConfiguration
to configure options oncevoid
unregister(String uri, String messageName)
Calls unregister of consumer by appropriate message name.-
Methods inherited from class org.apache.camel.support.DefaultComponent
afterConfiguration, createEndpoint, createEndpoint, doBuild, doInit, doStart, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getComponentPropertyConfigurer, getEndpointPropertyConfigurer, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, resolveRawParameterValues, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setLazyStartProducer, setProperties, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, 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, toString, wait, wait, wait
-
-
-
-
Method Detail
-
createEndpoint
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
A factory method allowing derived components to create a new endpoint from the given URI, remaining path and optional parameters- Specified by:
createEndpoint
in classorg.apache.camel.support.DefaultComponent
- Parameters:
uri
- the full URI of the endpointremaining
- the remaining part of the URI without the query parameters or component prefixparameters
- the optional parameters passed in- Returns:
- a newly created endpoint or null if the endpoint cannot be created based on the inputs
- Throws:
Exception
-
register
public void register(String uri, String messageName, AvroConsumer consumer) throws Exception
Registers new responder with uri as key. Registers consumer in responder. In case if responder is already registered by this uri then just registers consumer.- Parameters:
uri
- URI of the endpoint without message namemessageName
- message nameconsumer
- consumer that will be registered in providers` registry- Throws:
Exception
-
unregister
public void unregister(String uri, String messageName)
Calls unregister of consumer by appropriate message name. In case if all consumers are unregistered then it removes responder from the registry.- Parameters:
uri
- URI of the endpoint without message namemessageName
- message name
-
getConfiguration
public AvroConfiguration getConfiguration()
-
setConfiguration
public void setConfiguration(AvroConfiguration configuration)
To use a sharedAvroConfiguration
to configure options once
-
-