[camel-kafka-connector] branch master updated: Fixes typos when an invalid instance type is provided

[orpiske]

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


The following commit(s) were added to refs/heads/master by this push:
     new 956a72e  Fixes typos when an invalid instance type is provided
956a72e is described below

commit 956a72eda538edf3551a0099cc5cfdedb5d17305
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Tue Sep 22 13:32:52 2020 +0200

    Fixes typos when an invalid instance type is provided
---
 .../kafkaconnector/cassandra/services/CassandraServiceFactory.java      | 2 +-
 .../camel/kafkaconnector/common/services/kafka/KafkaServiceFactory.java | 2 +-
 .../elasticsearch/services/ElasticSearchServiceFactory.java             | 2 +-
 .../apache/camel/kafkaconnector/sjms2/services/JMSServiceFactory.java   | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/services/CassandraServiceFactory.java
 
b/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/services/CassandraServiceFactory.java
index 279d962..2ad4c8d 100644
--- 
a/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/services/CassandraServiceFactory.java
+++ 
b/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/services/CassandraServiceFactory.java
@@ -39,7 +39,7 @@ public final class CassandraServiceFactory {
         }
 
         LOG.error("Cassandra instance must be one of 
'local-cassandra-container' or 'remote");
-        throw new UnsupportedOperationException("Invalid Cassandra instance 
type:");
+        throw new UnsupportedOperationException("Invalid Cassandra instance 
type");
 
     }
 }
diff --git 
a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/KafkaServiceFactory.java
 
b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/KafkaServiceFactory.java
index c17ff42..0b671a6 100644
--- 
a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/KafkaServiceFactory.java
+++ 
b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/KafkaServiceFactory.java
@@ -48,7 +48,7 @@ public final class KafkaServiceFactory {
         }
 
         LOG.error("Kafka instance must be one of 'local-strimzi-container', 
'local-kafka-container', 'embedded' or 'remote");
-        throw new UnsupportedOperationException("Invalid Kafka instance 
type:");
+        throw new UnsupportedOperationException("Invalid Kafka instance type");
     }
 
 }
diff --git 
a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/services/ElasticSearchServiceFactory.java
 
b/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/services/ElasticSearchServiceFactory.java
index 71bc55c..8fbd704 100644
--- 
a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/services/ElasticSearchServiceFactory.java
+++ 
b/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/services/ElasticSearchServiceFactory.java
@@ -39,6 +39,6 @@ public final class ElasticSearchServiceFactory {
         }
 
         LOG.error("Cassandra instance must be one of 
'local-elasticsearch-container' or 'remote");
-        throw new UnsupportedOperationException("Invalid ElasticSearch 
instance type:");
+        throw new UnsupportedOperationException("Invalid ElasticSearch 
instance type");
     }
 }
diff --git 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/services/JMSServiceFactory.java
 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/services/JMSServiceFactory.java
index e74370e..572374a 100644
--- 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/services/JMSServiceFactory.java
+++ 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/services/JMSServiceFactory.java
@@ -43,6 +43,6 @@ public final class JMSServiceFactory {
 
         LOG.error("Invalid JMS instance type: {}. Must be one of 'remote', 
'local-artemis-container' or 'local-dispatch-router-container",
                 jmsInstanceType);
-        throw new UnsupportedOperationException("Invalid JMS instance type:");
+        throw new UnsupportedOperationException("Invalid JMS instance type");
     }
 }