public abstract class GenericPollingConsumer extends Object
Modifier and Type | Field and 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 and Description |
---|
GenericPollingConsumer(Properties properties,
String name,
org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
long scanInterval,
String injectingSeq,
String onErrorSeq,
boolean coordination,
boolean sequential) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
protected Properties |
getInboundProperties() |
protected boolean |
injectMessage(InputStream in,
String contentType) |
protected boolean |
injectMessage(String strMessage,
String contentType) |
abstract Object |
poll() |
protected Properties properties
protected String name
protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
protected long scanInterval
protected String injectingSeq
protected String onErrorSeq
protected boolean coordination
protected boolean sequential
public GenericPollingConsumer(Properties properties, String name, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, long scanInterval, String injectingSeq, String onErrorSeq, boolean coordination, boolean sequential)
public abstract Object poll()
public void destroy()
protected boolean injectMessage(InputStream in, String contentType)
protected Properties getInboundProperties()
Copyright © 2022 WSO2. All rights reserved.