Package org.wso2.carbon.inbound.endpoint.protocol.generic

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 final 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

Modifier and Type	Method	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

Methods inherited from class java.lang.Object

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

Field Details

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 Details

GenericEventBasedConsumer

public GenericEventBasedConsumer(Properties properties,
 String name,
 org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
 String injectingSeq,
 String onErrorSeq,
 boolean coordination,
 boolean sequential)

Method Details

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(String strMessage,
 String contentType)

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