Class GenericPollingConsumer
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer
-
public abstract class GenericPollingConsumer extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
coordination
protected String
injectingSeq
protected String
name
protected String
onErrorSeq
protected Properties
properties
protected long
scanInterval
protected boolean
sequential
protected org.apache.synapse.core.SynapseEnvironment
synapseEnvironment
-
Constructor Summary
Constructors Constructor Description GenericPollingConsumer(Properties properties, String name, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, long scanInterval, String injectingSeq, String onErrorSeq, boolean coordination, boolean sequential)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
destroy()
protected Properties
getInboundProperties()
protected boolean
injectMessage(InputStream in, String contentType)
protected boolean
injectMessage(String strMessage, String contentType)
abstract Object
poll()
-
-
-
Field Detail
-
properties
protected Properties properties
-
name
protected String name
-
synapseEnvironment
protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
-
scanInterval
protected long scanInterval
-
injectingSeq
protected String injectingSeq
-
onErrorSeq
protected String onErrorSeq
-
coordination
protected boolean coordination
-
sequential
protected boolean sequential
-
-
Constructor Detail
-
GenericPollingConsumer
public GenericPollingConsumer(Properties properties, String name, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, long scanInterval, String injectingSeq, String onErrorSeq, boolean coordination, boolean sequential)
-
-
Method Detail
-
poll
public abstract Object poll()
-
destroy
public void destroy()
-
injectMessage
protected boolean injectMessage(InputStream in, String contentType)
-
getInboundProperties
protected Properties getInboundProperties()
-
-