Package org.wso2.carbon.mediator.bam
Class Stream
- java.lang.Object
-
- org.wso2.carbon.mediator.bam.Stream
-
public class Stream extends Object
This is the main class of the Event Stream that extract data from mediator and send events.
-
-
Field Summary
Fields Modifier and Type Field Description static String
CLOUD_DEPLOYMENT_PROP
static String
DEFAULT_BAM_SERVER_URL
static String
ENABLE_MEDIATION_STATS
static String
SERVER_CONFIG_BAM_URL
-
Constructor Summary
Constructors Constructor Description Stream()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.wso2.carbon.mediator.bam.config.stream.StreamConfiguration
getStreamConfiguration()
void
sendEvents(org.apache.synapse.MessageContext messageContext)
void
setBamServerConfig(org.wso2.carbon.mediator.bam.config.BamServerConfig bamServerConfig)
void
setStreamConfiguration(org.wso2.carbon.mediator.bam.config.stream.StreamConfiguration streamConfiguration)
-
-
-
Field Detail
-
ENABLE_MEDIATION_STATS
public static final String ENABLE_MEDIATION_STATS
- See Also:
- Constant Field Values
-
CLOUD_DEPLOYMENT_PROP
public static final String CLOUD_DEPLOYMENT_PROP
- See Also:
- Constant Field Values
-
SERVER_CONFIG_BAM_URL
public static final String SERVER_CONFIG_BAM_URL
- See Also:
- Constant Field Values
-
DEFAULT_BAM_SERVER_URL
public static final String DEFAULT_BAM_SERVER_URL
- See Also:
- Constant Field Values
-
-
Method Detail
-
sendEvents
public void sendEvents(org.apache.synapse.MessageContext messageContext) throws org.wso2.carbon.mediator.bam.config.BamMediatorException
- Throws:
org.wso2.carbon.mediator.bam.config.BamMediatorException
-
setBamServerConfig
public void setBamServerConfig(org.wso2.carbon.mediator.bam.config.BamServerConfig bamServerConfig)
-
setStreamConfiguration
public void setStreamConfiguration(org.wso2.carbon.mediator.bam.config.stream.StreamConfiguration streamConfiguration)
-
getStreamConfiguration
public org.wso2.carbon.mediator.bam.config.stream.StreamConfiguration getStreamConfiguration()
-
-