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 f72fd6e Camel-AWS MSK: No need to set operation header in tests, it's
already set as uri parameter
f72fd6e is described below
commit f72fd6e9fbd04e48501c1c43c214f4efccdfb08f
Author: Andrea Cosentino <[email protected]>
AuthorDate: Wed Mar 20 16:27:09 2019 +0100
Camel-AWS MSK: No need to set operation header in tests, it's already set
as uri parameter
---
.../org/apache/camel/component/aws/msk/MSKProducerSpringTest.java | 4 ----
.../java/org/apache/camel/component/aws/msk/MSKProducerTest.java | 5 -----
2 files changed, 9 deletions(-)
diff --git
a/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerSpringTest.java
b/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerSpringTest.java
index 669af7c..37f98c8 100644
---
a/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerSpringTest.java
+++
b/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerSpringTest.java
@@ -43,7 +43,6 @@ public class MSKProducerSpringTest extends
CamelSpringTestSupport {
Exchange exchange = template.request("direct:listClusters", new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(MSKConstants.OPERATION,
MSKOperations.listClusters);
}
});
@@ -61,7 +60,6 @@ public class MSKProducerSpringTest extends
CamelSpringTestSupport {
Exchange exchange = template.request("direct:createCluster", new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(MSKConstants.OPERATION,
MSKOperations.createCluster);
exchange.getIn().setHeader(MSKConstants.CLUSTER_NAME,
"test-kafka");
exchange.getIn().setHeader(MSKConstants.CLUSTER_KAFKA_VERSION,
"2.1.1");
exchange.getIn().setHeader(MSKConstants.BROKER_NODES_NUMBER,
2);
@@ -84,7 +82,6 @@ public class MSKProducerSpringTest extends
CamelSpringTestSupport {
Exchange exchange = template.request("direct:deleteCluster", new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(MSKConstants.OPERATION,
MSKOperations.deleteCluster);
exchange.getIn().setHeader(MSKConstants.CLUSTER_ARN,
"test-kafka");
}
});
@@ -104,7 +101,6 @@ public class MSKProducerSpringTest extends
CamelSpringTestSupport {
Exchange exchange = template.request("direct:describeCluster", new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(MSKConstants.OPERATION,
MSKOperations.describeCluster);
exchange.getIn().setHeader(MSKConstants.CLUSTER_ARN,
"test-kafka");
}
});
diff --git
a/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerTest.java
b/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerTest.java
index f699f5c..2d2912e 100644
---
a/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerTest.java
+++
b/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerTest.java
@@ -20,7 +20,6 @@ import com.amazonaws.services.kafka.model.BrokerNodeGroupInfo;
import com.amazonaws.services.kafka.model.ClusterState;
import com.amazonaws.services.kafka.model.CreateClusterResult;
import com.amazonaws.services.kafka.model.DeleteClusterResult;
-import com.amazonaws.services.kafka.model.DescribeClusterRequest;
import com.amazonaws.services.kafka.model.DescribeClusterResult;
import com.amazonaws.services.kafka.model.ListClustersResult;
@@ -48,7 +47,6 @@ public class MSKProducerTest extends CamelTestSupport {
Exchange exchange = template.request("direct:listClusters", new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(MSKConstants.OPERATION,
MSKOperations.listClusters);
}
});
@@ -66,7 +64,6 @@ public class MSKProducerTest extends CamelTestSupport {
Exchange exchange = template.request("direct:createCluster", new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(MSKConstants.OPERATION,
MSKOperations.createCluster);
exchange.getIn().setHeader(MSKConstants.CLUSTER_NAME,
"test-kafka");
exchange.getIn().setHeader(MSKConstants.CLUSTER_KAFKA_VERSION,
"2.1.1");
exchange.getIn().setHeader(MSKConstants.BROKER_NODES_NUMBER,
2);
@@ -89,7 +86,6 @@ public class MSKProducerTest extends CamelTestSupport {
Exchange exchange = template.request("direct:deleteCluster", new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(MSKConstants.OPERATION,
MSKOperations.deleteCluster);
exchange.getIn().setHeader(MSKConstants.CLUSTER_ARN,
"test-kafka");
}
});
@@ -108,7 +104,6 @@ public class MSKProducerTest extends CamelTestSupport {
Exchange exchange = template.request("direct:describeCluster", new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(MSKConstants.OPERATION,
MSKOperations.describeCluster);
exchange.getIn().setHeader(MSKConstants.CLUSTER_ARN,
"test-kafka");
}
});
