luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Removing CommonsLog and replacing it wil Slf4j. (#318)

Browse source
This commit is contained in:
Sahil Palvia 2018-03-19 11:17:56 -07:00 committed by GitHub
parent ae49097c49
commit 9a3164f087
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/SimpleRecordsFetcherFactory.java
View file

@ -16,12 +16,12 @@ package software.amazon.kinesis.retrieval;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import software.amazon.kinesis.metrics.IMetricsFactory;
import com.google.common.util.concurrent.ThreadFactoryBuilder; import com.google.common.util.concurrent.ThreadFactoryBuilder;
import lombok.extern.apachecommons.CommonsLog; import lombok.extern.slf4j.Slf4j;
import software.amazon.kinesis.metrics.IMetricsFactory;
@CommonsLog @Slf4j
public class SimpleRecordsFetcherFactory implements RecordsFetcherFactory { public class SimpleRecordsFetcherFactory implements RecordsFetcherFactory {
private int maxPendingProcessRecordsInput = 3; private int maxPendingProcessRecordsInput = 3;
private int maxByteSize = 8 * 1024 * 1024; private int maxByteSize = 8 * 1024 * 1024;

10
amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/PrefetchGetRecordsCacheIntegrationTest.java
View file

@ -33,7 +33,6 @@ import java.util.List;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import software.amazon.kinesis.leases.ShardInfo;
import org.junit.After; import org.junit.After;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -43,19 +42,20 @@ import org.mockito.invocation.InvocationOnMock;
import org.mockito.runners.MockitoJUnitRunner; import org.mockito.runners.MockitoJUnitRunner;
import org.mockito.stubbing.Answer; import org.mockito.stubbing.Answer;
import software.amazon.kinesis.lifecycle.ProcessRecordsInput;
import software.amazon.kinesis.metrics.NullMetricsFactory;
import com.amazonaws.services.kinesis.model.ExpiredIteratorException; import com.amazonaws.services.kinesis.model.ExpiredIteratorException;
import com.amazonaws.services.kinesis.model.GetRecordsResult; import com.amazonaws.services.kinesis.model.GetRecordsResult;
import com.amazonaws.services.kinesis.model.Record; import com.amazonaws.services.kinesis.model.Record;
import lombok.extern.apachecommons.CommonsLog; import lombok.extern.slf4j.Slf4j;
import software.amazon.kinesis.leases.ShardInfo;
import software.amazon.kinesis.lifecycle.ProcessRecordsInput;
import software.amazon.kinesis.metrics.NullMetricsFactory;
/** /**
* These are the integration tests for the PrefetchGetRecordsCache class. * These are the integration tests for the PrefetchGetRecordsCache class.
*/ */
@RunWith(MockitoJUnitRunner.class) @RunWith(MockitoJUnitRunner.class)
@CommonsLog @Slf4j
public class PrefetchGetRecordsCacheIntegrationTest { public class PrefetchGetRecordsCacheIntegrationTest {
private static final int MAX_SIZE = 3; private static final int MAX_SIZE = 3;
private static final int MAX_BYTE_SIZE = 5 * 1024 * 1024; private static final int MAX_BYTE_SIZE = 5 * 1024 * 1024;