Class KnativeComponent

  • 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("knative")
    public class KnativeComponent
    extends org.apache.camel.support.DefaultComponent
    • Constructor Detail

      • KnativeComponent

        public KnativeComponent()
      • KnativeComponent

        public KnativeComponent​(org.apache.camel.CamelContext context)
    • Method Detail

      • setConfiguration

        public void setConfiguration​(KnativeConfiguration configuration)
        Set the configuration.
      • getEnvironmentPath

        public String getEnvironmentPath()
      • setEnvironmentPath

        public void setEnvironmentPath​(String environmentPath)
        The path ot the environment definition
      • setEnvironment

        public void setEnvironment​(KnativeEnvironment environment)
        The environment
      • getCloudEventsSpecVersion

        public String getCloudEventsSpecVersion()
      • setCloudEventsSpecVersion

        public void setCloudEventsSpecVersion​(String cloudEventSpecVersion)
        Set the version of the cloudevents spec.
      • setProducerFactory

        public void setProducerFactory​(KnativeProducerFactory producerFactory)
        The protocol producer factory.
      • setConsumerFactory

        public void setConsumerFactory​(KnativeConsumerFactory consumerFactory)
        The protocol consumer factory.
      • setTransportOptions

        public void setTransportOptions​(Map<String,​Object> transportOptions)
        Transport options.
      • doInit

        protected void doInit()
                       throws Exception
        Overrides:
        doInit in class org.apache.camel.support.DefaultComponent
        Throws:
        Exception
      • doStart

        protected void doStart()
                        throws Exception
        Overrides:
        doStart in class org.apache.camel.support.DefaultComponent
        Throws:
        Exception
      • doStop

        protected void doStop()
                       throws Exception
        Overrides:
        doStop in class org.apache.camel.support.DefaultComponent
        Throws:
        Exception
      • createEndpoint

        protected org.apache.camel.Endpoint createEndpoint​(String uri,
                                                           String remaining,
                                                           Map<String,​Object> parameters)
                                                    throws Exception
        Specified by:
        createEndpoint in class org.apache.camel.support.DefaultComponent
        Throws:
        Exception