Package com.activequant.tools.streaming

Examples of com.activequant.tools.streaming.StreamEvent


    long eventCount = 0;
    // iterate over all data and feed it into the event bus.
    while (fs.moreDataInPipe()) {

      //
      StreamEvent se = fs.getOneFromPipes();
      ETransportType transportType = se.getEventType();

      // only time events are sent to the generic transport layer.
      if (transportType.equals(ETransportType.TIME)) {
        transportFactory.getPublisher(transportType.toString())
            .send(se);
View Full Code Here


    // initialize also the headstart data.
   
    for (int i = 0; i < it.length; i++) {
      if (it[i].hasNext()) {
       
        StreamEvent payload = it[i].next();
        FastStreamEventContainer fs = new FastStreamEventContainer(i);
        fs.streamEvent=payload;
        fastQueue.add(fs);
      }
    }
View Full Code Here

    }
  }

  public StreamEvent getOneFromPipes()
  {
    StreamEvent ret = null;
    if(!fastQueue.isEmpty()){
      FastStreamEventContainer event = fastQueue.poll();
      if(event==null)return ret;
      ret = event.streamEvent;
      if(iterators[event.internalStreamId].hasNext())
      {        
        StreamEvent payload = iterators[event.internalStreamId].next();
        event.streamEvent=payload;
        fastQueue.add(event);
      }
    }
    return ret;
View Full Code Here

TOP

Related Classes of com.activequant.tools.streaming.StreamEvent

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.