public void onFailure()

in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java [83:91]

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

		public void onFailure(Throwable t) {
			if (t instanceof UserRecordFailedException) {
				Attempt last = Iterables.getLast(((UserRecordFailedException) t).getResult().getAttempts());
				putException =  new RetriableException("Kinesis Producer was not able to publish data - " + last.getErrorCode() + "-"
						+ last.getErrorMessage());
				return;
			}
			putException = new RetriableException("Exception during Kinesis put", t);
		}