Class KAFKAProcessor

  • All Implemented Interfaces:
    org.apache.synapse.inbound.InboundRequestProcessor, org.apache.synapse.inbound.InboundTaskProcessor, org.apache.synapse.task.TaskStartupObserver

    public class KAFKAProcessor
    extends InboundRequestProcessorImpl
    implements org.apache.synapse.task.TaskStartupObserver, org.apache.synapse.inbound.InboundTaskProcessor
    • Constructor Detail

      • KAFKAProcessor

        public KAFKAProcessor​(org.apache.synapse.inbound.InboundProcessorParams params)
    • Method Detail

      • init

        public void init()
        This will be called at the time of synapse artifact deployment.
        Specified by:
        init in interface org.apache.synapse.inbound.InboundRequestProcessor
      • start

        public void start()
        Register/start the schedule service
      • update

        public void update()
        Specified by:
        update in interface org.apache.synapse.task.TaskStartupObserver
      • getName

        public String getName()
      • setName

        public void setName​(String name)
      • destroy

        public void destroy()
        Description copied from class: InboundRequestProcessorImpl
        Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop
        Specified by:
        destroy in interface org.apache.synapse.inbound.InboundRequestProcessor
        Overrides:
        destroy in class InboundRequestProcessorImpl
      • destroy

        public void destroy​(boolean removeTask)
        Remove inbound endpoints.
        Specified by:
        destroy in interface org.apache.synapse.inbound.InboundTaskProcessor
        Parameters:
        removeTask - Whether to remove scheduled task from the registry or not.