public class KAFKAProcessor extends InboundRequestProcessorImpl implements org.apache.synapse.task.TaskStartupObserver
COMMON_ENDPOINT_POSTFIX, coordination, interval, name, synapseEnvironment
Constructor and Description |
---|
KAFKAProcessor(org.apache.synapse.inbound.InboundProcessorParams params) |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Stop the inbound polling processor This will be called when inbound is
undeployed/redeployed or when server stop
|
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() |
isPinnedServer, isPinnedServerEnabled, start
public KAFKAProcessor(org.apache.synapse.inbound.InboundProcessorParams params)
public void init()
init
in interface org.apache.synapse.inbound.InboundRequestProcessor
public void start()
public void update()
update
in interface org.apache.synapse.task.TaskStartupObserver
public String getName()
public void setName(String name)
public void destroy()
InboundRequestProcessorImpl
destroy
in interface org.apache.synapse.inbound.InboundRequestProcessor
destroy
in class InboundRequestProcessorImpl
Copyright © 2017 WSO2. All rights reserved.