You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/11/19 12:16:06 UTC
[camel] branch main updated (02b9b26 -> bb7ec67)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 02b9b26 Camel-YAML DSL: The throttle test should use the number of messages as 5 or not 5s
new a9a808e (chores) camel-hbase: remove unused exceptions
new bb7ec67 (chores) camel-hbase: prevent integration test from blocking the exection for too long
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/main/java/org/apache/camel/component/hbase/HBaseProducer.java | 4 ++--
.../test/java/org/apache/camel/component/hbase/HBaseProducerIT.java | 2 ++
2 files changed, 4 insertions(+), 2 deletions(-)
[camel] 02/02: (chores) camel-hbase: prevent integration test from blocking the exection for too long
Posted by or...@apache.org.
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 bb7ec67ccb77a7d8cea370b3792b30c89efd3b60
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Fri Nov 19 11:40:07 2021 +0100
(chores) camel-hbase: prevent integration test from blocking the exection for too long
---
.../src/test/java/org/apache/camel/component/hbase/HBaseProducerIT.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/components/camel-hbase/src/test/java/org/apache/camel/component/hbase/HBaseProducerIT.java b/components/camel-hbase/src/test/java/org/apache/camel/component/hbase/HBaseProducerIT.java
index b690ed6..c1f32b3 100644
--- a/components/camel-hbase/src/test/java/org/apache/camel/component/hbase/HBaseProducerIT.java
+++ b/components/camel-hbase/src/test/java/org/apache/camel/component/hbase/HBaseProducerIT.java
@@ -30,12 +30,14 @@ import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
+@Timeout(30)
public class HBaseProducerIT extends CamelHBaseTestSupport {
@Test
[camel] 01/02: (chores) camel-hbase: remove unused exceptions
Posted by or...@apache.org.
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 a9a808e81957dc47ece6bf54a1a60f03984ab9a3
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Fri Nov 19 11:39:03 2021 +0100
(chores) camel-hbase: remove unused exceptions
---
.../src/main/java/org/apache/camel/component/hbase/HBaseProducer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseProducer.java b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseProducer.java
index f17101b..076ee6c 100644
--- a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseProducer.java
+++ b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseProducer.java
@@ -104,7 +104,7 @@ public class HBaseProducer extends DefaultProducer {
/**
* Creates an HBase {@link Put} on a specific row, using a collection of values (family/column/value pairs).
*/
- private Put createPut(HBaseRow hRow) throws Exception {
+ private Put createPut(HBaseRow hRow) {
ObjectHelper.notNull(hRow, "HBase row");
ObjectHelper.notNull(hRow.getId(), "HBase row id");
ObjectHelper.notNull(hRow.getCells(), "HBase cells");
@@ -181,7 +181,7 @@ public class HBaseProducer extends DefaultProducer {
/**
* Creates an HBase {@link Delete} on a specific row, using a collection of values (family/column/value pairs).
*/
- private Delete createDeleteRow(HBaseRow hRow) throws Exception {
+ private Delete createDeleteRow(HBaseRow hRow) {
ObjectHelper.notNull(hRow, "HBase row");
ObjectHelper.notNull(hRow.getId(), "HBase row id");
return new Delete(endpoint.getCamelContext().getTypeConverter().convertTo(byte[].class, hRow.getId()));