public class KAFKAProcessor extends InboundRequestProcessorImpl implements org.apache.synapse.task.TaskStartupObserver, org.apache.synapse.inbound.InboundTaskProcessor
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
|
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() |
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
public void destroy(boolean removeTask)
destroy
in interface org.apache.synapse.inbound.InboundTaskProcessor
removeTask
- Whether to remove scheduled task from the registry or not.Copyright © 2017 WSO2. All rights reserved.