public class Stream extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CLOUD_DEPLOYMENT_PROP |
static String |
DEFAULT_BAM_SERVER_URL |
static String |
ENABLE_MEDIATION_STATS |
static String |
SERVER_CONFIG_BAM_URL |
Constructor and Description |
---|
Stream() |
Modifier and Type | Method and 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) |
public static final String ENABLE_MEDIATION_STATS
public static final String CLOUD_DEPLOYMENT_PROP
public static final String SERVER_CONFIG_BAM_URL
public static final String DEFAULT_BAM_SERVER_URL
public void sendEvents(org.apache.synapse.MessageContext messageContext) throws org.wso2.carbon.mediator.bam.config.BamMediatorException
org.wso2.carbon.mediator.bam.config.BamMediatorException
public void setBamServerConfig(org.wso2.carbon.mediator.bam.config.BamServerConfig bamServerConfig)
public void setStreamConfiguration(org.wso2.carbon.mediator.bam.config.stream.StreamConfiguration streamConfiguration)
public org.wso2.carbon.mediator.bam.config.stream.StreamConfiguration getStreamConfiguration()
Copyright © 2021 WSO2. All rights reserved.