[camel] branch master updated: Camel-AWS2-MQ: Don't use ActiveMQ as default EngineType in createBroker operation, since now there is also RabbitMQ as supported engine

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 5e47682  Camel-AWS2-MQ: Don't use ActiveMQ as default EngineType in createBroker operation, since now there is also RabbitMQ as supported engine
5e47682 is described below

commit 5e476829ae758a1dda3e1b3539b4853eb921f6bc
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Nov 16 08:45:37 2020 +0100

    Camel-AWS2-MQ: Don't use ActiveMQ as default EngineType in createBroker operation, since now there is also RabbitMQ as supported engine
---
 .../src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java b/components/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java
index 25376da..7fa537f 100644
--- a/components/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java
+++ b/components/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java
@@ -176,7 +176,7 @@ public class MQ2Producer extends DefaultProducer {
                 brokerEngine = exchange.getIn().getHeader(MQ2Constants.BROKER_ENGINE, String.class);
                 builder.engineType(EngineType.fromValue(brokerEngine));
             } else {
-                builder.engineType(EngineType.ACTIVEMQ.name());
+                throw new IllegalArgumentException("A broker engine must be specified, it can be ACTIVEMQ or RABBITMQ");
             }
             if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(MQ2Constants.BROKER_ENGINE_VERSION))) {
                 brokerEngineVersion = exchange.getIn().getHeader(MQ2Constants.BROKER_ENGINE_VERSION, String.class);