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

Fixing tests to run with Travis. Travis doesn't have default aws setup, so the client builders need the region to be passed.

Browse source
This commit is contained in:
Sahil Palvia 2018-03-05 11:30:43 -08:00
parent 4826fd6a6f
commit ac610f318f
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/WorkerTest.java
View file

@ -1651,9 +1651,9 @@ public class WorkerTest {
.withKinesisEndpoint(endpoint)
.withDynamoDBEndpoint(endpoint);
AmazonKinesis kinesisClient = spy(AmazonKinesisClientBuilder.defaultClient());
AmazonDynamoDB dynamoDBClient = spy(AmazonDynamoDBClientBuilder.defaultClient());
AmazonCloudWatch cloudWatchClient = spy(AmazonCloudWatchClientBuilder.defaultClient());
AmazonKinesis kinesisClient = spy(AmazonKinesisClientBuilder.standard().withRegion(Regions.US_EAST_1).build());
AmazonDynamoDB dynamoDBClient = spy(AmazonDynamoDBClientBuilder.standard().withRegion(Regions.US_EAST_1).build());
AmazonCloudWatch cloudWatchClient = spy(AmazonCloudWatchClientBuilder.standard().withRegion(Regions.US_EAST_1).build());
new Worker.Builder().recordProcessorFactory(recordProcessorFactory).config(config)
.kinesisClient(kinesisClient)
@ -1679,9 +1679,9 @@ public class WorkerTest {
Worker.Builder builder = new Worker.Builder();
AmazonKinesis kinesisClient = spy(AmazonKinesisClientBuilder.defaultClient());
AmazonDynamoDB dynamoDBClient = spy(AmazonDynamoDBClientBuilder.defaultClient());
AmazonCloudWatch cloudWatchClient = spy(AmazonCloudWatchClientBuilder.defaultClient());
AmazonKinesis kinesisClient = spy(AmazonKinesisClientBuilder.standard().withRegion(Regions.US_EAST_1).build());
AmazonDynamoDB dynamoDBClient = spy(AmazonDynamoDBClientBuilder.standard().withRegion(Regions.US_EAST_1).build());
AmazonCloudWatch cloudWatchClient = spy(AmazonCloudWatchClientBuilder.standard().withRegion(Regions.US_EAST_1).build());
builder.recordProcessorFactory(recordProcessorFactory).config(config)
.kinesisClient(kinesisClient)