DataCollectionStack.java

private void createMobileCollectionResource(RestApi api, String platformResourceName) {
  Resource mobileResource = api.getRoot().addResource(platformResourceName);
  KinesisPipeline pipeline = createKinesisPipeline(platformResourceName);
  kinesisPipelines.add(pipeline);
  AnalyticsEventProcessor processor = AnalyticsEventProcessor.Builder.create(this,
          String.format("Analytics%sEventProcessor", capitalize(platformResourceName)))
      .platformName(platformResourceName)
      .stream(pipeline.getStream())
      .lambdaExecutionRole(awsLambdaAnalyticsExecution)
      .routingLambda(routingLambda)
      .reprocessingLambda(reprocessingLambda)
      .build();
  lambdaDlqTopics.add(processor.getDlqTopic());
  Resource batch = mobileResource.addResource("batch");
  attachStreamResourceMethods(batch, platformResourceName, "PutRecords", false);
  Resource sourceConfig = mobileResource.addResource("sourceConfig");
  sourceConfig.addMethod("GET",
      createSourceConfigMockIntegration(false),
      createMethodOptions(false)
  );
}