Examples of com.linkedin.databus.core.DbusEventBuffer.start()

Class com.linkedin.databus.core.DbusEventBuffer

Examples of com.linkedin.databus.core.DbusEventBuffer.start()

com.linkedin.databus.core.DbusEventBuffer.start()

      LogicalSource lsrc = new LogicalSource((int)lid, srcName);
      DbusEventBuffer buf = relay.getEventBuffer().getDbusEventBuffer(lsrc);
      byte [] schema = "abcdefghijklmnop".getBytes(Charset.defaultCharset());
      final long prevScn = 99;
      final long eventScn = 101;
      buf.start(prevScn);
      buf.startEvents();
      Assert.assertTrue(buf.appendEvent(new DbusEventKey(1),
                                        (short) 100,
                                        (short) 0,
                                        System.currentTimeMillis() * 1000000,

View Full Code Here


    DatabusSourcesConnection.StaticConfig connConfig = confBuilder.build();
    // internal buffers of databus client library
    DbusEventBuffer buffer = new DbusEventBuffer(
        connConfig.getEventBuffer());
    buffer.start(0);


    DbusEventBuffer bootstrapBuffer = null;
    // Create threadpools and netty managers
    // read - write timeout in ms
    long readTimeoutMs = connTimeoutMs;

View Full Code Here

          }
        }


        DbusEventBuffer eventBuffer = connConfig.getEventBuffer().getOrCreateEventBuffer(_eventFactory);
        eventBuffer.setDropOldEvents(true);
        eventBuffer.start(0);




        DbusEventBuffer bootstrapBuffer = null;
        // create bootstrap only if it is enabled
        if(_clientStaticConfig.getRuntime().getBootstrap().isEnabled()) {

View Full Code Here

        DbusEventBuffer bootstrapBuffer = null;
        // create bootstrap only if it is enabled
        if(_clientStaticConfig.getRuntime().getBootstrap().isEnabled()) {
          bootstrapBuffer = new DbusEventBuffer(connConfig.getEventBuffer());
          bootstrapBuffer.setDropOldEvents(false);
          bootstrapBuffer.start(0);
        }


        LOG.info("The sourcesList is " + sourcesStrList);
        LOG.info("The relayGroupStreamConsumers is " + getRelayGroupStreamConsumers().get(subsList));

View Full Code Here

                                          cfg.getRestoreMMappedBuffers(),
                                          cfg.getRestoreMMappedBuffersValidateEvents(),
                                          cfg.isEnableScnIndex(),
                                          _client.getEventFactory());
        eventBuffer.setDropOldEvents(true);
        eventBuffer.start(0);
    }


    DbusEventBuffer bootstrapBuffer = null;
    if (enableBootstrap && canConsumerBootstrap)
    {

View Full Code Here

                                            bstCfg.getRestoreMMappedBuffers(),
                                            bstCfg.getRestoreMMappedBuffersValidateEvents(),
                                            bstCfg.isEnableScnIndex(),
                                            _client.getEventFactory());
      bootstrapBuffer.setDropOldEvents(false);
      bootstrapBuffer.start(0);
    }


    List<DatabusSubscription> subs = createSubscriptions(_sources);


    if (null != _checkpointPersistenceProvider && _client.getClientStaticConfig().getCheckpointPersistence().isClearBeforeUse())

View Full Code Here

  }


  private DbusEventBuffer createSimpleBuffer()
  {
    DbusEventBuffer buf  = new DbusEventBuffer(_bufCfg);
    buf.start(0);
    buf.startEvents();
    buf.appendEvent(new DbusEventKey(1), (short)1, (short)1, System.nanoTime(), (short)1,
                    new byte[16], new byte[100], false, null);
    buf.appendEvent(new DbusEventKey(2), (short)1, (short)1, System.nanoTime(), (short)1,
                    new byte[16], new byte[100], false, null);

View Full Code Here

      // TODO this should actually use DbusEventBufferAppendable (DDSDBUS-78)
      DbusEventBuffer buf = (DbusEventBuffer)_eventBuffer.getDbusEventBufferAppendable(pPartition);
      if(buf == null)
        throw new RequestProcessingException("cannot find buffer for ph. partion " + pPartition);


      if ((buf.getMinScn() < 0) && (buf.getPrevScn() < 0)) buf.start(0);


      try
      {
        DbusEventsStatisticsCollector statsCollector = _relay.getInBoundStatsCollectors().getStatsCollector(pPartition.toSimpleString());

View Full Code Here

        Hashtable<Long, AtomicInteger> keyCounts = new Hashtable<Long, AtomicInteger>();
        Hashtable<Short, AtomicInteger> srcidCounts = new Hashtable<Short, AtomicInteger>();


    // Send dummy e
        DbusEventBuffer eventsBuf = dsc.getDataEventsBuffer();
        eventsBuf.start(0);
        eventsBuf.startEvents();
        initBufferWithEvents(eventsBuf, 1, source1EventsNum, (short)1, keyCounts, srcidCounts);
        initBufferWithEvents(eventsBuf, 1 + source1EventsNum, source2EventsNum, (short)2, keyCounts, srcidCounts);
        eventsBuf.endEvents(100L,null);

View Full Code Here

        final int eventsNum = 20;
        DbusEventInfo[] eventInfos = createSampleSchema1Events(eventsNum);


        //simulate relay buffers
        DbusEventBuffer relayBuffer = new DbusEventBuffer(_bufCfg);
        relayBuffer.start(0);
        writeEventsToBuffer(relayBuffer, eventInfos, 4);


        //prepare stream response
        Checkpoint cp = Checkpoint.createFlexibleCheckpoint();
        final DbusEventsStatisticsCollector stats =

View Full Code Here

0 1 2

TOP

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.