Class GenericProcessor
java.lang.Object
org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl
org.wso2.carbon.inbound.endpoint.protocol.generic.GenericProcessor
- All Implemented Interfaces:
org.apache.synapse.inbound.InboundRequestProcessor,org.apache.synapse.task.TaskStartupObserver
public class GenericProcessor
extends InboundRequestProcessorImpl
implements org.apache.synapse.task.TaskStartupObserver
-
Field Summary
Fields inherited from class org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl
COMMON_ENDPOINT_POSTFIX, coordination, interval, name, startInPausedMode, synapseEnvironment -
Constructor Summary
ConstructorsConstructorDescriptionGenericProcessor(String name, String classImpl, Properties properties, long scanInterval, String injectingSeq, String onErrorSeq, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, boolean coordination, boolean sequential) GenericProcessor(org.apache.synapse.inbound.InboundProcessorParams params) -
Method Summary
Methods inherited from class org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl
activate, deactivate, isDeactivated, isPinnedServer, isPinnedServerEnabled, pause, start
-
Constructor Details
-
GenericProcessor
public GenericProcessor(String name, String classImpl, Properties properties, long scanInterval, String injectingSeq, String onErrorSeq, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, boolean coordination, boolean sequential) -
GenericProcessor
public GenericProcessor(org.apache.synapse.inbound.InboundProcessorParams params)
-
-
Method Details
-
init
public void init()- Specified by:
initin interfaceorg.apache.synapse.inbound.InboundRequestProcessor
-
start
public void start() -
destroy
public void destroy()Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop- Specified by:
destroyin interfaceorg.apache.synapse.inbound.InboundRequestProcessor- Overrides:
destroyin classInboundRequestProcessorImpl
-
getName
-
setName
-
update
public void update()- Specified by:
updatein interfaceorg.apache.synapse.task.TaskStartupObserver
-