Fixes typos when an invalid instance type is provided
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 @@
}
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 @@
}
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 @@
}
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 @@
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");
}
}
