This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit ebb15f04c154cb1632b2c9593db59083a2d6a06d
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Mar 8 14:41:06 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-aws2-kinesis
---
.../KinesisFirehoseComponentVerifierExtensionTest.java | 6 +++---
.../component/aws2/firehose/KinesisFirehoseEndpointTest.java | 6 +++---
.../integration/KinesisFirehoseComponentManualIT.java | 12 ++++++------
.../aws2/kinesis/KinesisComponentVerifierExtensionTest.java | 6 +++---
.../aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java | 4 ++--
.../kinesis/KinesisConsumerClosedShardWithSilentTest.java | 2 +-
.../camel/component/aws2/kinesis/KinesisEndpointTest.java | 10 +++++-----
.../component/aws2/kinesis/RecordStringConverterTest.java | 2 +-
.../aws2/kinesis/integration/KinesisComponentManualIT.java | 8 ++++----
9 files changed, 28 insertions(+), 28 deletions(-)
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/KinesisFirehoseComponentVerifierExtensionTest.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/KinesisFirehoseComponentVerifierExtensionTest.java
index f47d0eb..5d3b9d2 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/KinesisFirehoseComponentVerifierExtensionTest.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/KinesisFirehoseComponentVerifierExtensionTest.java
@@ -37,7 +37,7 @@ public class KinesisFirehoseComponentVerifierExtensionTest
extends CamelTestSupp
}
@Test
- public void testParameters() throws Exception {
+ public void testParameters() {
Component component = context().getComponent("aws2-kinesis-firehose");
ComponentVerifierExtension verifier
@@ -55,7 +55,7 @@ public class KinesisFirehoseComponentVerifierExtensionTest
extends CamelTestSupp
}
@Test
- public void testConnectivity() throws Exception {
+ public void testConnectivity() {
Component component = context().getComponent("aws2-kinesis-firehose");
ComponentVerifierExtension verifier
=
component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
@@ -72,7 +72,7 @@ public class KinesisFirehoseComponentVerifierExtensionTest
extends CamelTestSupp
}
@Test
- public void testConnectivityAndRegion() throws Exception {
+ public void testConnectivityAndRegion() {
Component component = context().getComponent("aws2-kinesis-firehose");
ComponentVerifierExtension verifier
=
component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/KinesisFirehoseEndpointTest.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/KinesisFirehoseEndpointTest.java
index 042e67c..249b8cf 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/KinesisFirehoseEndpointTest.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/KinesisFirehoseEndpointTest.java
@@ -39,14 +39,14 @@ public class KinesisFirehoseEndpointTest {
private CamelContext camelContext;
@BeforeEach
- public void setup() throws Exception {
+ public void setup() {
SimpleRegistry registry = new SimpleRegistry();
registry.bind("firehoseClient", amazonKinesisFirehoseClient);
camelContext = new DefaultCamelContext(registry);
}
@Test
- public void allEndpointParams() throws Exception {
+ public void allEndpointParams() {
KinesisFirehose2Endpoint endpoint = (KinesisFirehose2Endpoint)
camelContext
.getEndpoint("aws2-kinesis-firehose://some_stream_name" +
"?amazonKinesisFirehoseClient=#firehoseClient");
endpoint.start();
@@ -56,7 +56,7 @@ public class KinesisFirehoseEndpointTest {
}
@Test
- public void allClientCreationParams() throws Exception {
+ public void allClientCreationParams() {
KinesisFirehose2Endpoint endpoint = (KinesisFirehose2Endpoint)
camelContext
.getEndpoint("aws2-kinesis-firehose://some_stream_name" +
"?accessKey=xxx&secretKey=yyy®ion=us-east-1");
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/integration/KinesisFirehoseComponentManualIT.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/integration/KinesisFirehoseComponentManualIT.java
index 142e3d3..b851b17 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/integration/KinesisFirehoseComponentManualIT.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/firehose/integration/KinesisFirehoseComponentManualIT.java
@@ -42,9 +42,9 @@ public class KinesisFirehoseComponentManualIT extends
CamelTestSupport {
FirehoseClient client = FirehoseClient.builder().build();
@Test
- public void testFirehoseRouting() throws Exception {
+ public void testFirehoseRouting() {
Exchange exchange = template.send("direct:start",
ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody("my message text");
}
});
@@ -52,9 +52,9 @@ public class KinesisFirehoseComponentManualIT extends
CamelTestSupport {
}
@Test
- public void testFirehoseBatchRouting() throws Exception {
+ public void testFirehoseBatchRouting() {
Exchange exchange = template.send("direct:start",
ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
List<Record> recs = new ArrayList<Record>();
Record rec =
Record.builder().data(SdkBytes.fromString("Test1",
Charset.defaultCharset())).build();
Record rec1 =
Record.builder().data(SdkBytes.fromString("Test2",
Charset.defaultCharset())).build();
@@ -67,10 +67,10 @@ public class KinesisFirehoseComponentManualIT extends
CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("aws2-kinesis-firehose://cc?amazonKinesisFirehoseClient=#FirehoseClient&operation=sendBatchRecord");
}
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisComponentVerifierExtensionTest.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisComponentVerifierExtensionTest.java
index bf15fe1..4c6aac7 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisComponentVerifierExtensionTest.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisComponentVerifierExtensionTest.java
@@ -37,7 +37,7 @@ public class KinesisComponentVerifierExtensionTest extends
CamelTestSupport {
}
@Test
- public void testParameters() throws Exception {
+ public void testParameters() {
Component component = context().getComponent("aws2-kinesis");
ComponentVerifierExtension verifier
@@ -55,7 +55,7 @@ public class KinesisComponentVerifierExtensionTest extends
CamelTestSupport {
}
@Test
- public void testConnectivity() throws Exception {
+ public void testConnectivity() {
Component component = context().getComponent("aws2-kinesis");
ComponentVerifierExtension verifier
=
component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
@@ -72,7 +72,7 @@ public class KinesisComponentVerifierExtensionTest extends
CamelTestSupport {
}
@Test
- public void testConnectivityAndRegion() throws Exception {
+ public void testConnectivityAndRegion() {
Component component = context().getComponent("aws2-kinesis");
ComponentVerifierExtension verifier
=
component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java
index bd88e7f..55b718f 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java
@@ -60,7 +60,7 @@ public class KinesisConsumerClosedShardWithFailTest {
private Kinesis2Consumer undertest;
@BeforeEach
- public void setup() throws Exception {
+ public void setup() {
Kinesis2Configuration configuration = new Kinesis2Configuration();
configuration.setAmazonKinesisClient(kinesisClient);
configuration.setIteratorType(ShardIteratorType.LATEST);
@@ -85,7 +85,7 @@ public class KinesisConsumerClosedShardWithFailTest {
}
@Test
- public void itObtainsAShardIteratorOnFirstPoll() throws Exception {
+ public void itObtainsAShardIteratorOnFirstPoll() {
assertThrows(ReachedClosedStatusException.class, () -> {
undertest.poll();
});
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithSilentTest.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithSilentTest.java
index ce1ebac..3197f13 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithSilentTest.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithSilentTest.java
@@ -61,7 +61,7 @@ public class KinesisConsumerClosedShardWithSilentTest {
private Kinesis2Consumer undertest;
@BeforeEach
- public void setup() throws Exception {
+ public void setup() {
Kinesis2Configuration configuration = new Kinesis2Configuration();
configuration.setAmazonKinesisClient(kinesisClient);
configuration.setIteratorType(ShardIteratorType.LATEST);
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisEndpointTest.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisEndpointTest.java
index 5167423..b77a15c 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisEndpointTest.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisEndpointTest.java
@@ -39,14 +39,14 @@ public class KinesisEndpointTest {
private CamelContext camelContext;
@BeforeEach
- public void setup() throws Exception {
+ public void setup() {
SimpleRegistry registry = new SimpleRegistry();
registry.bind("kinesisClient", amazonKinesisClient);
camelContext = new DefaultCamelContext(registry);
}
@Test
- public void allTheEndpointParams() throws Exception {
+ public void allTheEndpointParams() {
Kinesis2Endpoint endpoint = (Kinesis2Endpoint) camelContext
.getEndpoint("aws2-kinesis://some_stream_name" +
"?amazonKinesisClient=#kinesisClient"
+ "&maxResultsPerRequest=101" +
"&iteratorType=latest" + "&shardId=abc" + "&sequenceNumber=123");
@@ -60,7 +60,7 @@ public class KinesisEndpointTest {
}
@Test
- public void onlyRequiredEndpointParams() throws Exception {
+ public void onlyRequiredEndpointParams() {
Kinesis2Endpoint endpoint = (Kinesis2Endpoint) camelContext
.getEndpoint("aws2-kinesis://some_stream_name" +
"?amazonKinesisClient=#kinesisClient");
@@ -71,7 +71,7 @@ public class KinesisEndpointTest {
}
@Test
- public void afterSequenceNumberRequiresSequenceNumber() throws Exception {
+ public void afterSequenceNumberRequiresSequenceNumber() {
Kinesis2Endpoint endpoint = (Kinesis2Endpoint) camelContext
.getEndpoint("aws2-kinesis://some_stream_name" +
"?amazonKinesisClient=#kinesisClient"
+ "&iteratorType=AFTER_SEQUENCE_NUMBER" +
"&shardId=abc" + "&sequenceNumber=123");
@@ -84,7 +84,7 @@ public class KinesisEndpointTest {
}
@Test
- public void atSequenceNumberRequiresSequenceNumber() throws Exception {
+ public void atSequenceNumberRequiresSequenceNumber() {
Kinesis2Endpoint endpoint = (Kinesis2Endpoint) camelContext
.getEndpoint("aws2-kinesis://some_stream_name" +
"?amazonKinesisClient=#kinesisClient"
+ "&iteratorType=AT_SEQUENCE_NUMBER" +
"&shardId=abc" + "&sequenceNumber=123");
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/RecordStringConverterTest.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/RecordStringConverterTest.java
index f3da19e..b37f214 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/RecordStringConverterTest.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/RecordStringConverterTest.java
@@ -29,7 +29,7 @@ import static org.hamcrest.MatcherAssert.assertThat;
public class RecordStringConverterTest {
@Test
- public void convertRecordToString() throws Exception {
+ public void convertRecordToString() {
Record record = Record.builder().sequenceNumber("1")
.data(SdkBytes.fromByteBuffer(ByteBuffer.wrap("this is a
String".getBytes(Charset.forName("UTF-8"))))).build();
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/integration/KinesisComponentManualIT.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/integration/KinesisComponentManualIT.java
index a47a7e0..bb009f6 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/integration/KinesisComponentManualIT.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/integration/KinesisComponentManualIT.java
@@ -51,14 +51,14 @@ public class KinesisComponentManualIT extends
CamelTestSupport {
result.expectedMessageCount(2);
template.send("direct:start", ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(Kinesis2Constants.PARTITION_KEY,
"partition-1");
exchange.getIn().setBody("Kinesis Event 1.");
}
});
template.send("direct:start", ExchangePattern.InOut, new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(Kinesis2Constants.PARTITION_KEY,
"partition-1");
exchange.getIn().setBody("Kinesis Event 2.");
}
@@ -79,10 +79,10 @@ public class KinesisComponentManualIT extends
CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
String kinesisEndpointUri =
"aws2-kinesis://kinesis1?amazonKinesisClient=#amazonKinesisClient";
from("direct:start").to(kinesisEndpointUri);
