Package org.wso2.carbon.inbound.endpoint.common

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 final String	COMMON_ENDPOINT_POSTFIX
protected boolean	coordination
protected long	interval
protected String	name
protected boolean	startInPausedMode
protected org.apache.synapse.core.SynapseEnvironment	synapseEnvironment

Constructor Summary

Constructors

Constructor	Description
InboundRequestProcessorImpl()

Method Summary

Modifier and Type	Method	Description
boolean	activate()
boolean	deactivate()
void	destroy()	Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop
boolean	isDeactivated()
protected boolean	isPinnedServer(Properties inboundProperties)
protected static boolean	isPinnedServerEnabled(Properties inboundProperties)
void	pause()
protected void	start(InboundTask task, String endpointPostfix)	Based on the coordination option schedule the task with NTASK or run as a background thread

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.synapse.inbound.InboundRequestProcessor

init

Field Details

synapseEnvironment

protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment

interval

protected long interval

name

protected String name

coordination

protected boolean coordination

startInPausedMode

protected boolean startInPausedMode

COMMON_ENDPOINT_POSTFIX

protected static final String COMMON_ENDPOINT_POSTFIX

See Also:

• Constant Field Values

Constructor Details

InboundRequestProcessorImpl

public InboundRequestProcessorImpl()

Method Details

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 interface org.apache.synapse.inbound.InboundRequestProcessor

isPinnedServerEnabled

protected static boolean isPinnedServerEnabled(Properties inboundProperties)

isPinnedServer

protected boolean isPinnedServer(Properties inboundProperties)

activate

public boolean activate()

Specified by:

activate in interface org.apache.synapse.inbound.InboundRequestProcessor

deactivate

public boolean deactivate()

Specified by:

deactivate in interface org.apache.synapse.inbound.InboundRequestProcessor

isDeactivated

public boolean isDeactivated()

Specified by:

isDeactivated in interface org.apache.synapse.inbound.InboundRequestProcessor

pause

public void pause()

Specified by:

pause in interface org.apache.synapse.inbound.InboundRequestProcessor