Package org.wso2.carbon.inbound.endpoint.protocol.kafka

Class KAFKAProcessor

java.lang.Object

org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl

org.wso2.carbon.inbound.endpoint.protocol.kafka.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

Field Summary

Fields inherited from class org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl

COMMON_ENDPOINT_POSTFIX, coordination, interval, name, startInPausedMode, synapseEnvironment

Constructor Summary

Constructors

Constructor	Description
KAFKAProcessor(org.apache.synapse.inbound.InboundProcessorParams params)

Method Summary

Modifier and Type	Method	Description
void	destroy()	Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop
void	destroy(boolean removeTask)	Remove inbound endpoints.
String	getName()
void	init()	This will be called at the time of synapse artifact deployment.
void	setName(String name)
void	start()	Register/start the schedule service
void	update()

Methods inherited from class org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl

activate, deactivate, isDeactivated, isPinnedServer, isPinnedServerEnabled, pause, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KAFKAProcessor

public KAFKAProcessor(org.apache.synapse.inbound.InboundProcessorParams params)

Method Details

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.