This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 03f9486c52912b9037bc04d81d2eef98cd47218d Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Wed Jan 13 15:26:01 2021 +0100 Use the StandardsCharset to avoid the UnsupportedEncodingException --- .../rabbitmq/sink/RabbitMQSinkITCase.java | 20 +++++++------------- 1 file changed, 7 insertions(+), 13 deletions(-) diff --git a/tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/RabbitMQSinkITCase.java b/tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/RabbitMQSinkITCase.java index 8635469..d2c3ad6 100644 --- a/tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/RabbitMQSinkITCase.java +++ b/tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/RabbitMQSinkITCase.java @@ -16,7 +16,7 @@ */ package org.apache.camel.kafkaconnector.rabbitmq.sink; -import java.io.UnsupportedEncodingException; +import java.nio.charset.StandardCharsets; import java.util.concurrent.CountDownLatch; import com.rabbitmq.client.DeliverCallback; @@ -63,22 +63,16 @@ public class RabbitMQSinkITCase extends AbstractKafkaTest { } private boolean checkRecord(Delivery rabbitMQDelivery) { - try { - String message = new String(rabbitMQDelivery.getBody(), "UTF-8"); - LOG.debug("Received: {}", message); - - received++; + String message = new String(rabbitMQDelivery.getBody(), StandardCharsets.UTF_8); + LOG.debug("Received: {}", message); - if (received == expect) { - return false; - } + received++; - return true; - } catch (UnsupportedEncodingException e) { - LOG.error("Failed to read message: {}", e.getMessage(), e); - fail("Failed to read message: " + e.getMessage()); + if (received == expect) { return false; } + + return true; } private void runBasicStringTest(ConnectorPropertyFactory connectorPropertyFactory) throws Exception {
