public class JMSProcessor extends InboundRequestProcessorImpl implements org.apache.synapse.task.TaskStartupObserver
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
|
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
Copyright © 2017 WSO2. All rights reserved.