private Boolean updateClickLogRequestToStream()

in source/clicklogger/src/main/java/com/clicklogs/Handlers/ClickLoggerHandler.java [121:141]

• 19 lines of code
• 2 McCabe index (conditional complexity)

  private Boolean updateClickLogRequestToStream(ClickLogRequest clickLogRequest) {
    System.out.println("Inside updateClickLogRequestToStream method for the input");
    try {

      AmazonKinesisFirehose amazonKinesisFirehoseClient = AmazonKinesisFirehoseClientBuilder.standard().withRegion(region).build();

      PutRecordRequest putRecordRequest = new PutRecordRequest();
      putRecordRequest.setDeliveryStreamName(stream_name);
      Gson gson = new Gson();
      String messageJson = gson.toJson(clickLogRequest);
      System.out.println("gson - " + messageJson);
      Record record = new Record().withData(ByteBuffer.wrap(messageJson.toString().getBytes()));
      putRecordRequest.setRecord(record);
      PutRecordResult putRecordResult = amazonKinesisFirehoseClient.putRecord( putRecordRequest );
      System.out.println("updated the stream for recordid - " + putRecordResult.getRecordId());
      return true;
    } catch (Exception e) {
      System.out.println("Error occurred - " + e.getMessage());
    }     
    return false;
  }