public class JMSProcessor extends InboundRequestProcessorImpl implements org.apache.synapse.task.TaskStartupObserver, org.apache.synapse.inbound.InboundTaskProcessor
COMMON_ENDPOINT_POSTFIX, coordination, interval, name, synapseEnvironment
Constructor and Description |
---|
JMSProcessor(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(JMSPollingConsumer pollingConsumer,
int consumer)
Register/start the schedule service
|
void |
update() |
isPinnedServer, isPinnedServerEnabled, start
public JMSProcessor(org.apache.synapse.inbound.InboundProcessorParams params)
public void init()
init
in interface org.apache.synapse.inbound.InboundRequestProcessor
public void destroy()
destroy
in interface org.apache.synapse.inbound.InboundRequestProcessor
destroy
in class InboundRequestProcessorImpl
public void start(JMSPollingConsumer pollingConsumer, int consumer)
public String getName()
public void setName(String name)
public void update()
update
in interface org.apache.synapse.task.TaskStartupObserver
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 © 2021 WSO2. All rights reserved.