tst/com/amazon/kinesis/streaming/agent/tailing/PublishingQueueTest.java [309:327]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        PublishingQueue<FirehoseRecord> q = getTestQueue();

        // Fill the queue up
        Stopwatch timer = Stopwatch.createStarted();
        while(q.size() < q.capacity()) {
            queueAndFlushBuffer(q);
        }
        Assert.assertEquals(q.size(), q.capacity());
        Assert.assertTrue(timer.elapsed(TimeUnit.MILLISECONDS) < maxWaitOnFullQueue);

        // Make sure we don't exceed the max batch limits
        timer = Stopwatch.createStarted();
        final int recordCount = flow.getMaxBufferSizeRecords();
        final int recordSize = flow.getMaxRecordSizeBytes() / recordCount / 2;
        final double recordSizeJitter = 0.0;
        RecordGenerator generator = new RecordGenerator(recordSize, recordSizeJitter);
        long totalBytes = 0;
        for(int i = 0; i < recordCount; ++i) {
            FirehoseRecord record = getTestRecord(flow, generator);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tst/com/amazon/kinesis/streaming/agent/tailing/PublishingQueueTest.java [694:712]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        PublishingQueue<FirehoseRecord> q = getTestQueue();

        // Fill the queue up
        Stopwatch timer = Stopwatch.createStarted();
        while(q.size() < q.capacity()) {
            queueAndFlushBuffer(q);
        }
        Assert.assertEquals(q.size(), q.capacity());
        Assert.assertTrue(timer.elapsed(TimeUnit.MILLISECONDS) < maxWaitOnFullQueue);

        // Make sure we don't exceed the max batch limits
        timer = Stopwatch.createStarted();
        final int recordCount = flow.getMaxBufferSizeRecords();
        final int recordSize = flow.getMaxRecordSizeBytes() / recordCount / 2;
        final double recordSizeJitter = 0.0;
        RecordGenerator generator = new RecordGenerator(recordSize, recordSizeJitter);
        long totalBytes = 0;
        for(int i = 0; i < recordCount; ++i) {
            FirehoseRecord record = getTestRecord(flow, generator);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -