You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/09/01 12:09:41 UTC
[camel] 02/05: Fixed CS
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit aa596fd90927ca0af731fcf983b6ac1cad8d096c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Sep 1 13:07:15 2020 +0200
Fixed CS
---
.../aws2/firehose/KinesisFirehose2Operations.java | 6 +-
.../aws2/firehose/KinesisFirehose2Producer.java | 71 +++++++++-------------
2 files changed, 31 insertions(+), 46 deletions(-)
diff --git a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Operations.java b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Operations.java
index 01aa840..bfd27a3 100644
--- a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Operations.java
+++ b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Operations.java
@@ -18,9 +18,5 @@ package org.apache.camel.component.aws2.firehose;
public enum KinesisFirehose2Operations {
- sendBatchRecord,
- createDeliveryStream,
- deleteDeliveryStream,
- describeDeliveryStream,
- updateDestination
+ sendBatchRecord, createDeliveryStream, deleteDeliveryStream, describeDeliveryStream, updateDestination
}
diff --git a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Producer.java b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Producer.java
index 5ab81a5..9e3fa42 100644
--- a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Producer.java
+++ b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Producer.java
@@ -51,7 +51,7 @@ public class KinesisFirehose2Producer extends DefaultProducer {
@Override
public KinesisFirehose2Endpoint getEndpoint() {
- return (KinesisFirehose2Endpoint) super.getEndpoint();
+ return (KinesisFirehose2Endpoint)super.getEndpoint();
}
@Override
@@ -61,23 +61,23 @@ public class KinesisFirehose2Producer extends DefaultProducer {
processSingleRecord(exchange);
} else {
switch (operation) {
- case sendBatchRecord:
- sendBatchRecord(getClient(), exchange);
- break;
- case createDeliveryStream:
- createDeliveryStream(getClient(), exchange);
- break;
- case deleteDeliveryStream:
- deleteDeliveryStream(getClient(), exchange);
- break;
- case updateDestination:
- updateDestination(getClient(), exchange);
- break;
- case describeDeliveryStream:
- describeDeliveryStream(getClient(), exchange);
- break;
- default:
- throw new IllegalArgumentException("Unsupported operation");
+ case sendBatchRecord:
+ sendBatchRecord(getClient(), exchange);
+ break;
+ case createDeliveryStream:
+ createDeliveryStream(getClient(), exchange);
+ break;
+ case deleteDeliveryStream:
+ deleteDeliveryStream(getClient(), exchange);
+ break;
+ case updateDestination:
+ updateDestination(getClient(), exchange);
+ break;
+ case describeDeliveryStream:
+ describeDeliveryStream(getClient(), exchange);
+ break;
+ default:
+ throw new IllegalArgumentException("Unsupported operation");
}
}
}
@@ -89,8 +89,7 @@ public class KinesisFirehose2Producer extends DefaultProducer {
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
- throw new IllegalArgumentException(
- "The createDeliveryStream operation expects a CreateDeliveryStream instance as body");
+ throw new IllegalArgumentException("The createDeliveryStream operation expects a CreateDeliveryStream instance as body");
}
}
@@ -102,17 +101,13 @@ public class KinesisFirehose2Producer extends DefaultProducer {
message.setBody(result);
} else {
if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(KinesisFirehose2Constants.KINESIS_FIREHOSE_STREAM_NAME))) {
- DeleteDeliveryStreamRequest req
- = DeleteDeliveryStreamRequest.builder()
- .deliveryStreamName(exchange.getIn()
- .getHeader(KinesisFirehose2Constants.KINESIS_FIREHOSE_STREAM_NAME, String.class))
- .build();
+ DeleteDeliveryStreamRequest req = DeleteDeliveryStreamRequest.builder()
+ .deliveryStreamName(exchange.getIn().getHeader(KinesisFirehose2Constants.KINESIS_FIREHOSE_STREAM_NAME, String.class)).build();
DeleteDeliveryStreamResponse result = client.deleteDeliveryStream(req);
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
- throw new IllegalArgumentException(
- "The deleteDeliveryStream operation expects at least an delivery stream name header or a DeleteDeliveryStreamRequest instance");
+ throw new IllegalArgumentException("The deleteDeliveryStream operation expects at least an delivery stream name header or a DeleteDeliveryStreamRequest instance");
}
}
}
@@ -124,30 +119,25 @@ public class KinesisFirehose2Producer extends DefaultProducer {
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
- throw new IllegalArgumentException(
- "The updateDestination operation expects an UpdateDestinationRequest instance as body");
+ throw new IllegalArgumentException("The updateDestination operation expects an UpdateDestinationRequest instance as body");
}
}
-
+
private void describeDeliveryStream(FirehoseClient client, Exchange exchange) {
if (exchange.getIn().getBody() instanceof DescribeDeliveryStreamRequest) {
- DescribeDeliveryStreamRequest req = exchange.getIn().getBody(DescribeDeliveryStreamRequest.class);
+ DescribeDeliveryStreamRequest req = exchange.getIn().getBody(DescribeDeliveryStreamRequest.class);
DescribeDeliveryStreamResponse result = client.describeDeliveryStream(req);
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(KinesisFirehose2Constants.KINESIS_FIREHOSE_STREAM_NAME))) {
- DescribeDeliveryStreamRequest req
- = DescribeDeliveryStreamRequest.builder()
- .deliveryStreamName(exchange.getIn()
- .getHeader(KinesisFirehose2Constants.KINESIS_FIREHOSE_STREAM_NAME, String.class))
- .build();
+ DescribeDeliveryStreamRequest req = DescribeDeliveryStreamRequest.builder()
+ .deliveryStreamName(exchange.getIn().getHeader(KinesisFirehose2Constants.KINESIS_FIREHOSE_STREAM_NAME, String.class)).build();
DescribeDeliveryStreamResponse result = client.describeDeliveryStream(req);
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
- throw new IllegalArgumentException(
- "The describeDeliveryStream operation expects at least an delivery stream name header or a DeleteDeliveryStreamRequest instance");
+ throw new IllegalArgumentException("The describeDeliveryStream operation expects at least an delivery stream name header or a DeleteDeliveryStreamRequest instance");
}
}
}
@@ -157,7 +147,7 @@ public class KinesisFirehose2Producer extends DefaultProducer {
Iterable c = exchange.getIn().getBody(Iterable.class);
PutRecordBatchRequest.Builder batchRequest = PutRecordBatchRequest.builder();
batchRequest.deliveryStreamName(getEndpoint().getConfiguration().getStreamName());
- batchRequest.records((Collection<Record>) c);
+ batchRequest.records((Collection<Record>)c);
PutRecordBatchResponse result = client.putRecordBatch(batchRequest.build());
Message message = getMessageForResponse(exchange);
message.setBody(result);
@@ -202,8 +192,7 @@ public class KinesisFirehose2Producer extends DefaultProducer {
}
private KinesisFirehose2Operations determineOperation(Exchange exchange) {
- KinesisFirehose2Operations operation = exchange.getIn().getHeader(KinesisFirehose2Constants.KINESIS_FIREHOSE_OPERATION,
- KinesisFirehose2Operations.class);
+ KinesisFirehose2Operations operation = exchange.getIn().getHeader(KinesisFirehose2Constants.KINESIS_FIREHOSE_OPERATION, KinesisFirehose2Operations.class);
if (operation == null) {
operation = getConfiguration().getOperation();
}