@Test(timeout = 180000) public void sendsOnlyWhenMaxBucketsFull() { assertEquals(0, appender.getSendSuccessCount()); assertEquals(0, httpServer.requestCount()); appendFullBuckets(MAX_BUCKETS); httpServer.waitForRequests(MAX_BUCKETS); assertEquals(MAX_BUCKETS, appender.getSendSuccessCount()); assertEquals(MAX_BUCKETS, httpServer.requestCount()); }
@Override public int getSendSuccessCount() { return sendSuccessCount.get(); }
LogglyBatchAppender extends AbstractLogglyAppender<E> implements LogglyBatchAppenderMBean { @Override public int getSendSuccessCount() { return sendSuccessCount.get(); } }
LogglyBatchAppender extends AbstractLogglyAppender<E> implements LogglyBatchAppenderMBean { @Override public int getSendSuccessCount() { return sendSuccessCount.get(); }  }
LogglyBatchAppender extends AbstractLogglyAppender<E> implements LogglyBatchAppenderMBean { @Override public int getSendSuccessCount() { return sendSuccessCount.get(); }  @Override void start(); @Override void stop(); @Override void processLogEntries(); int getFlushIntervalInSeconds(); void setFlushIntervalInSeconds(int flushIntervalInSeconds); @Override long getSentBytes(); @Override long getSendDurationInNanos(); @Override int getSendSuccessCount(); @Override int getSendExceptionCount(); @Override int getDiscardedBucketsCount(); @Override long getCurrentLogEntriesBufferSizeInBytes(); void setDebug(boolean debug); boolean isDebug(); void setJmxMonitoring(boolean jmxMonitoring); void setMbeanServer(MBeanServer mbeanServer); void setMaxNumberOfBuckets(int maxNumberOfBuckets); void setMaxBucketSizeInKilobytes(int maxBucketSizeInKilobytes); void setConnReadTimeoutSeconds(int connReadTimeoutSeconds); }
LogglyBatchAppender extends AbstractLogglyAppender<E> implements LogglyBatchAppenderMBean { @Override public int getSendSuccessCount() { return sendSuccessCount.get(); }  @Override void start(); @Override void stop(); @Override void processLogEntries(); int getFlushIntervalInSeconds(); void setFlushIntervalInSeconds(int flushIntervalInSeconds); @Override long getSentBytes(); @Override long getSendDurationInNanos(); @Override int getSendSuccessCount(); @Override int getSendExceptionCount(); @Override int getDiscardedBucketsCount(); @Override long getCurrentLogEntriesBufferSizeInBytes(); void setDebug(boolean debug); boolean isDebug(); void setJmxMonitoring(boolean jmxMonitoring); void setMbeanServer(MBeanServer mbeanServer); void setMaxNumberOfBuckets(int maxNumberOfBuckets); void setMaxBucketSizeInKilobytes(int maxBucketSizeInKilobytes); void setConnReadTimeoutSeconds(int connReadTimeoutSeconds); static final String ENDPOINT_URL_PATH; }