Class JMSProcessor
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl
-
- org.wso2.carbon.inbound.endpoint.protocol.jms.JMSProcessor
-
- All Implemented Interfaces:
org.apache.synapse.inbound.InboundRequestProcessor
,org.apache.synapse.inbound.InboundTaskProcessor
,org.apache.synapse.task.TaskStartupObserver
public class JMSProcessor 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, synapseEnvironment
-
-
Constructor Summary
Constructors Constructor Description JMSProcessor(org.apache.synapse.inbound.InboundProcessorParams params)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stopvoid
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 servicevoid
update()
-
Methods inherited from class org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl
isPinnedServer, isPinnedServerEnabled, start
-
-
-
-
Method Detail
-
init
public void init()
This will be called at the time of synapse artifact deployment.- Specified by:
init
in interfaceorg.apache.synapse.inbound.InboundRequestProcessor
-
destroy
public void destroy()
Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop- Specified by:
destroy
in interfaceorg.apache.synapse.inbound.InboundRequestProcessor
- Overrides:
destroy
in classInboundRequestProcessorImpl
-
start
public void start(JMSPollingConsumer pollingConsumer, int consumer)
Register/start the schedule service
-
getName
public String getName()
-
setName
public void setName(String name)
-
update
public void update()
- Specified by:
update
in interfaceorg.apache.synapse.task.TaskStartupObserver
-
destroy
public void destroy(boolean removeTask)
Remove inbound endpoints.- Specified by:
destroy
in interfaceorg.apache.synapse.inbound.InboundTaskProcessor
- Parameters:
removeTask
- Whether to remove scheduled task from the registry or not.
-
-