public abstract class GenericEventBasedConsumer extends Object
Modifier and Type | Field and Description |
---|---|
protected boolean |
coordination |
protected String |
injectingSeq |
protected String |
name |
protected String |
onErrorSeq |
static String |
PARAM_INBOUND_ENDPOINT_BEHAVIOR_EVENT_BASED |
protected Properties |
properties |
protected boolean |
sequential |
protected org.apache.synapse.core.SynapseEnvironment |
synapseEnvironment |
Constructor and Description |
---|
GenericEventBasedConsumer(Properties properties,
String name,
org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
String injectingSeq,
String onErrorSeq,
boolean coordination,
boolean sequential) |
Modifier and Type | Method and Description |
---|---|
abstract void |
destroy()
This methods needs to be implemented when terminating the inbound
|
protected boolean |
injectMessage(InputStream in,
String contentType) |
protected boolean |
injectMessage(String strMessage,
String contentType) |
static boolean |
isEventBasedInboundEndpoint(org.apache.synapse.inbound.InboundProcessorParams inboundParameters)
States whether generic endpoint is a eventBased
Return true; if eventBased
|
abstract void |
listen()
This methods needs to be implemented when implementing the custom inbound
|
public static final String PARAM_INBOUND_ENDPOINT_BEHAVIOR_EVENT_BASED
protected Properties properties
protected String name
protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
protected String injectingSeq
protected String onErrorSeq
protected boolean coordination
protected boolean sequential
public GenericEventBasedConsumer(Properties properties, String name, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, String injectingSeq, String onErrorSeq, boolean coordination, boolean sequential)
public abstract void listen()
public abstract void destroy()
protected boolean injectMessage(InputStream in, String contentType)
public static boolean isEventBasedInboundEndpoint(org.apache.synapse.inbound.InboundProcessorParams inboundParameters)
inboundParameters
- Inbound Parameters for endpointCopyright © 2020 WSO2. All rights reserved.