Class GenericEventBasedConsumer
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.protocol.generic.GenericEventBasedConsumer
-
public abstract class GenericEventBasedConsumer extends Object
-
-
Field Summary
Fields Modifier and Type Field 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 Summary
Constructors Constructor Description GenericEventBasedConsumer(Properties properties, String name, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, String injectingSeq, String onErrorSeq, boolean coordination, boolean sequential)
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract void
destroy()
This methods needs to be implemented when terminating the inboundprotected 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 eventBasedabstract void
listen()
This methods needs to be implemented when implementing the custom inbound
-
-
-
Field Detail
-
PARAM_INBOUND_ENDPOINT_BEHAVIOR_EVENT_BASED
public static final String PARAM_INBOUND_ENDPOINT_BEHAVIOR_EVENT_BASED
- See Also:
- Constant Field Values
-
properties
protected Properties properties
-
name
protected String name
-
synapseEnvironment
protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
-
injectingSeq
protected String injectingSeq
-
onErrorSeq
protected String onErrorSeq
-
coordination
protected boolean coordination
-
sequential
protected boolean sequential
-
-
Constructor Detail
-
GenericEventBasedConsumer
public GenericEventBasedConsumer(Properties properties, String name, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, String injectingSeq, String onErrorSeq, boolean coordination, boolean sequential)
-
-
Method Detail
-
listen
public abstract void listen()
This methods needs to be implemented when implementing the custom inbound
-
destroy
public abstract void destroy()
This methods needs to be implemented when terminating the inbound
-
injectMessage
protected boolean injectMessage(InputStream in, String contentType)
-
isEventBasedInboundEndpoint
public static boolean isEventBasedInboundEndpoint(org.apache.synapse.inbound.InboundProcessorParams inboundParameters)
States whether generic endpoint is a eventBased Return true; if eventBased- Parameters:
inboundParameters
- Inbound Parameters for endpoint- Returns:
- boolean
-
-