public abstract class InboundRequestProcessorImpl extends Object implements org.apache.synapse.inbound.InboundRequestProcessor
Modifier and Type | Field and Description |
---|---|
protected static String |
COMMON_ENDPOINT_POSTFIX |
protected boolean |
coordination |
protected long |
interval |
protected String |
name |
protected org.apache.synapse.core.SynapseEnvironment |
synapseEnvironment |
Constructor and Description |
---|
InboundRequestProcessorImpl() |
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
|
protected 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
|
protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
protected long interval
protected String name
protected boolean coordination
protected static final String COMMON_ENDPOINT_POSTFIX
protected void start(InboundTask task, String endpointPostfix)
task
- endpointPostfix
- public void destroy()
destroy
in interface org.apache.synapse.inbound.InboundRequestProcessor
protected static boolean isPinnedServerEnabled(Properties inboundProperties)
protected boolean isPinnedServer(Properties inboundProperties)
Copyright © 2018 WSO2. All rights reserved.