Class InboundRequestProcessorImpl
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.common.InboundRequestProcessorImpl
-
- All Implemented Interfaces:
org.apache.synapse.inbound.InboundRequestProcessor
- Direct Known Subclasses:
GenericProcessor
,JMSProcessor
,KAFKAProcessor
public abstract class InboundRequestProcessorImpl extends Object implements org.apache.synapse.inbound.InboundRequestProcessor
This class provides the common implementation for polling protocol processors
-
-
Field Summary
Fields Modifier and Type Field Description protected static String
COMMON_ENDPOINT_POSTFIX
protected boolean
coordination
protected long
interval
protected String
name
protected org.apache.synapse.core.SynapseEnvironment
synapseEnvironment
-
Constructor Summary
Constructors Constructor Description InboundRequestProcessorImpl()
-
Method Summary
All Methods Static 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 stopprotected boolean
isPinnedServer(Properties inboundProperties)
protected static boolean
isPinnedServerEnabled(Properties inboundProperties)
protected void
start(InboundTask task, String endpointPostfix)
Based on the coordination option schedule the task with NTASK or run as a background thread
-
-
-
Field Detail
-
synapseEnvironment
protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
-
interval
protected long interval
-
name
protected String name
-
coordination
protected boolean coordination
-
COMMON_ENDPOINT_POSTFIX
protected static final String COMMON_ENDPOINT_POSTFIX
- See Also:
- Constant Field Values
-
-
Method Detail
-
start
protected void start(InboundTask task, String endpointPostfix)
Based on the coordination option schedule the task with NTASK or run as a background thread- Parameters:
task
-endpointPostfix
-
-
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
-
isPinnedServerEnabled
protected static boolean isPinnedServerEnabled(Properties inboundProperties)
-
isPinnedServer
protected boolean isPinnedServer(Properties inboundProperties)
-
-