Class Stream


  • public class Stream
    extends Object
    This is the main class of the Event Stream that extract data from mediator and send events.
    • Constructor Detail

      • Stream

        public Stream()
    • 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()