Class 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
    • Field Summary

      • Fields inherited from class org.apache.camel.support.service.BaseService

        BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING
    • 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 parameters
      AvroConfiguration getConfiguration()  
      void register​(String uri, String messageName, AvroConsumer consumer)
      Registers new responder with uri as key.
      void setConfiguration​(AvroConfiguration configuration)
      To use a shared AvroConfiguration to configure options once
      void 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 interface org.apache.camel.Service

        build, close, init, start, stop
      • Methods inherited from interface org.apache.camel.ShutdownableService

        shutdown
      • Methods inherited from interface org.apache.camel.StatefulService

        getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending
      • Methods inherited from interface org.apache.camel.SuspendableService

        isSuspended, resume, suspend
    • Constructor Detail

      • AvroComponent

        public AvroComponent()
      • AvroComponent

        public AvroComponent​(org.apache.camel.CamelContext context)
    • 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 class org.apache.camel.support.DefaultComponent
        Parameters:
        uri - the full URI of the endpoint
        remaining - the remaining part of the URI without the query parameters or component prefix
        parameters - 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 name
        messageName - message name
        consumer - 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 name
        messageName - message name