Repository: camel Updated Branches: refs/heads/master f545ca78b -> ba13226da
Polish Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ba13226d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ba13226d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ba13226d Branch: refs/heads/master Commit: ba13226da9c11f9b053b43f3ab73409bfe14658f Parents: f545ca7 Author: Babak Vahdat <bvah...@apache.org> Authored: Tue Dec 29 18:42:22 2015 +0100 Committer: Babak Vahdat <bvah...@apache.org> Committed: Tue Dec 29 18:42:22 2015 +0100 ---------------------------------------------------------------------- .../ignite/cache/IgniteCacheContinuousQueryConsumer.java | 2 -- .../apache/camel/component/infinispan/InfinispanOperation.java | 6 +++--- .../org/apache/camel/component/jbpm/JBPMConfiguration.java | 1 - .../camel/component/jclouds/JcloudsSpringBlobstoreTest.java | 3 --- .../camel/component/jms/issues/JmsReplyToLoopIssueTest.java | 4 ---- .../org/apache/camel/processor/jpa/JpaProducerRemoveTest.java | 1 - .../src/main/java/org/apache/camel/jsonpath/JsonStream.java | 2 +- .../apache/camel/component/kafka/KafkaProducerFullTest.java | 2 -- .../camel/component/kafka/embedded/EmbeddedZookeeper.java | 1 - .../kubernetes/consumer/KubernetesNamespacesConsumer.java | 2 +- .../component/kubernetes/consumer/KubernetesPodsConsumer.java | 2 +- .../consumer/KubernetesReplicationControllersConsumer.java | 2 +- .../kubernetes/consumer/KubernetesSecretsConsumer.java | 2 +- .../kubernetes/consumer/KubernetesServicesConsumer.java | 2 +- .../kubernetes/producer/KubernetesBuildConfigsProducer.java | 1 - .../kubernetes/producer/KubernetesBuildsProducer.java | 1 - .../kubernetes/producer/KubernetesNamespacesProducer.java | 1 - .../component/kubernetes/producer/KubernetesNodesProducer.java | 1 - .../producer/KubernetesPersistentVolumesClaimsProducer.java | 2 -- .../producer/KubernetesPersistentVolumesProducer.java | 2 -- .../producer/KubernetesReplicationControllersProducer.java | 2 -- .../kubernetes/producer/KubernetesResourcesQuotaProducer.java | 2 -- .../kubernetes/producer/KubernetesSecretsProducer.java | 2 -- .../kubernetes/producer/KubernetesServiceAccountsProducer.java | 2 -- .../kubernetes/producer/KubernetesServicesProducer.java | 2 -- .../kubernetes/consumer/KubernetesNamespacesConsumerTest.java | 2 +- .../kubernetes/producer/KubernetesBuildsProducerTest.java | 3 --- .../kubernetes/producer/KubernetesNamespacesProducerTest.java | 5 ++--- .../kubernetes/producer/KubernetesNodesProducerTest.java | 5 ----- .../KubernetesPersistentVolumesClaimsProducerTest.java | 3 +-- .../producer/KubernetesPersistentVolumesProducerTest.java | 2 -- .../kubernetes/producer/KubernetesPodsProducerTest.java | 5 ++--- .../producer/KubernetesReplicationControllersProducerTest.java | 5 ++--- .../producer/KubernetesResourcesQuotaProducerTest.java | 1 - .../kubernetes/producer/KubernetesSecretsProducerTest.java | 1 - .../producer/KubernetesServiceAccountsProducerTest.java | 3 +-- .../kubernetes/producer/KubernetesServicesProducerTest.java | 5 ++--- .../org/apache/camel/component/mongodb/MongoDbEndpoint.java | 2 -- .../org/apache/camel/component/mongodb/MongoDbProducer.java | 1 - .../org/apache/camel/component/mqtt/MQTTConfiguration.java | 1 - 40 files changed, 20 insertions(+), 74 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheContinuousQueryConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheContinuousQueryConsumer.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheContinuousQueryConsumer.java index cb06424..b4feea5 100644 --- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheContinuousQueryConsumer.java +++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheContinuousQueryConsumer.java @@ -16,8 +16,6 @@ */ package org.apache.camel.component.ignite.cache; -import java.util.Arrays; - import javax.cache.Cache.Entry; import javax.cache.event.CacheEntryEvent; import javax.cache.event.CacheEntryListenerException; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java ---------------------------------------------------------------------- diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java index 4d37c9a..6a4f0ab 100644 --- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java +++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java @@ -65,7 +65,7 @@ public class InfinispanOperation { if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT))) { long maxIdle = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME, long.class); - String maxIdleTimeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); + String maxIdleTimeUnit = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); result = cache.put(getKey(exchange), getValue(exchange), lifespan, TimeUnit.valueOf(timeUnit), maxIdle, TimeUnit.valueOf(maxIdleTimeUnit)); } else { result = cache.put(getKey(exchange), getValue(exchange), lifespan, TimeUnit.valueOf(timeUnit)); @@ -85,7 +85,7 @@ public class InfinispanOperation { if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT))) { long maxIdle = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME, long.class); - String maxIdleTimeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); + String maxIdleTimeUnit = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); result = cache.putAsync(getKey(exchange), getValue(exchange), lifespan, TimeUnit.valueOf(timeUnit), maxIdle, TimeUnit.valueOf(maxIdleTimeUnit)); } else { result = cache.putAsync(getKey(exchange), getValue(exchange), lifespan, TimeUnit.valueOf(timeUnit)); @@ -123,7 +123,7 @@ public class InfinispanOperation { if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT))) { long maxIdle = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME, long.class); - String maxIdleTimeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); + String maxIdleTimeUnit = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); result = cache.putAllAsync(getMap(exchange), lifespan, TimeUnit.valueOf(timeUnit), maxIdle, TimeUnit.valueOf(maxIdleTimeUnit)); } else { result = cache.putAllAsync(getMap(exchange), lifespan, TimeUnit.valueOf(timeUnit)); http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMConfiguration.java b/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMConfiguration.java index 961e439..6f26d5d 100644 --- a/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMConfiguration.java +++ b/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMConfiguration.java @@ -19,7 +19,6 @@ package org.apache.camel.component.jbpm; import java.net.URL; import java.util.List; import java.util.Map; -import javax.naming.InitialContext; import org.apache.camel.spi.Metadata; import org.apache.camel.spi.UriParam; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java b/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java index 2834ffa..9d55797 100644 --- a/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java +++ b/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java @@ -20,16 +20,13 @@ import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.Set; import org.apache.camel.EndpointInject; -import org.apache.camel.Exchange; import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.test.spring.CamelSpringTestSupport; import org.jclouds.ContextBuilder; import org.jclouds.blobstore.BlobStore; import org.jclouds.blobstore.BlobStoreContext; -import org.jclouds.compute.domain.Image; import org.junit.BeforeClass; import org.junit.Test; import org.springframework.context.support.AbstractApplicationContext; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java index 059c1cf..b297338 100644 --- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java +++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsReplyToLoopIssueTest.java @@ -19,12 +19,8 @@ package org.apache.camel.component.jms.issues; import javax.jms.ConnectionFactory; import org.apache.camel.CamelContext; -import org.apache.camel.Exchange; -import org.apache.camel.ExchangePattern; -import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.jms.CamelJmsTestHelper; -import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.test.junit4.CamelTestSupport; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaProducerRemoveTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaProducerRemoveTest.java b/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaProducerRemoveTest.java index 69f03ac..e076522 100644 --- a/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaProducerRemoveTest.java +++ b/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaProducerRemoveTest.java @@ -21,7 +21,6 @@ import javax.persistence.EntityManagerFactory; import org.apache.camel.Exchange; import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jpa.JpaConstants; import org.apache.camel.component.jpa.JpaEndpoint; import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.examples.SendEmail; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java ---------------------------------------------------------------------- diff --git a/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java b/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java index d0daa5a..63a0d41 100644 --- a/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java +++ b/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java @@ -264,7 +264,7 @@ public class JsonStream extends FilterInputStream { @Override public long skip(long n) throws IOException { if (inputIndex < inputEnd) { - long minimum = Math.min(n, (long) (inputEnd - inputIndex)); + long minimum = Math.min(n, inputEnd - inputIndex); for (int i = 0; i < minimum; i++) { inputIndex++; } http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java index d76a059..7934f41 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java @@ -35,9 +35,7 @@ import org.apache.camel.EndpointInject; import org.apache.camel.Produce; import org.apache.camel.ProducerTemplate; import org.apache.camel.builder.RouteBuilder; -import org.junit.After; import org.junit.AfterClass; -import org.junit.Before; import org.junit.BeforeClass; import org.junit.Test; import org.slf4j.Logger; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedZookeeper.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedZookeeper.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedZookeeper.java index 0ba2c77..41762c9 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedZookeeper.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedZookeeper.java @@ -21,7 +21,6 @@ import java.io.FileNotFoundException; import java.io.IOException; import java.net.InetSocketAddress; -import org.apache.zookeeper.server.NIOServerCnxnFactory; import org.apache.zookeeper.server.ServerCnxnFactory; import org.apache.zookeeper.server.ZooKeeperServer; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumer.java index ffb6665..f08c4dd 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumer.java @@ -106,7 +106,7 @@ public class KubernetesNamespacesConsumer extends ScheduledPollConsumer { protected int poll() throws Exception { int mapSize = map.size(); for (ConcurrentMap.Entry<Long, NamespaceEvent> entry : map.entrySet()) { - NamespaceEvent namespaceEvent = (NamespaceEvent) entry.getValue(); + NamespaceEvent namespaceEvent = entry.getValue(); Exchange e = getEndpoint().createExchange(); e.getIn().setBody(namespaceEvent.getNamespace()); e.getIn().setHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION, namespaceEvent.getAction()); http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumer.java index 09ee7e8..bfa025e 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumer.java @@ -104,7 +104,7 @@ public class KubernetesPodsConsumer extends ScheduledPollConsumer { protected int poll() throws Exception { int mapSize = map.size(); for (ConcurrentMap.Entry<Long, PodEvent> entry : map.entrySet()) { - PodEvent podEvent = (PodEvent) entry.getValue(); + PodEvent podEvent = entry.getValue(); Exchange e = getEndpoint().createExchange(); e.getIn().setBody(podEvent.getPod()); e.getIn().setHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION, podEvent.getAction()); http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumer.java index 4c8d1e8..e7fd348 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumer.java @@ -108,7 +108,7 @@ public class KubernetesReplicationControllersConsumer extends ScheduledPollConsu protected int poll() throws Exception { int mapSize = map.size(); for (ConcurrentMap.Entry<Long, ReplicationControllerEvent> entry : map.entrySet()) { - ReplicationControllerEvent serviceEvent = (ReplicationControllerEvent) entry.getValue(); + ReplicationControllerEvent serviceEvent = entry.getValue(); Exchange e = getEndpoint().createExchange(); e.getIn().setBody(serviceEvent.getReplicationController()); e.getIn().setHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION, serviceEvent.getAction()); http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumer.java index 09ab19a..1a47321 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumer.java @@ -104,7 +104,7 @@ public class KubernetesSecretsConsumer extends ScheduledPollConsumer { protected int poll() throws Exception { int mapSize = map.size(); for (ConcurrentMap.Entry<Long, SecretEvent> entry : map.entrySet()) { - SecretEvent podEvent = (SecretEvent) entry.getValue(); + SecretEvent podEvent = entry.getValue(); Exchange e = getEndpoint().createExchange(); e.getIn().setBody(podEvent.getSecret()); e.getIn().setHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION, podEvent.getAction()); http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumer.java index fc68648..b32a06e 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumer.java @@ -106,7 +106,7 @@ public class KubernetesServicesConsumer extends ScheduledPollConsumer { protected int poll() throws Exception { int mapSize = map.size(); for (ConcurrentMap.Entry<Long, ServiceEvent> entry : map.entrySet()) { - ServiceEvent serviceEvent = (ServiceEvent) entry.getValue(); + ServiceEvent serviceEvent = entry.getValue(); Exchange e = getEndpoint().createExchange(); e.getIn().setBody(serviceEvent.getService()); e.getIn().setHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION, serviceEvent.getAction()); http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildConfigsProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildConfigsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildConfigsProducer.java index acaaea1..154321e 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildConfigsProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildConfigsProducer.java @@ -20,7 +20,6 @@ import java.util.Map; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.openshift.api.model.BuildConfig; import io.fabric8.openshift.api.model.BuildConfigList; import io.fabric8.openshift.api.model.DoneableBuildConfig; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducer.java index 8c3273e..d21d9c4 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducer.java @@ -20,7 +20,6 @@ import java.util.Map; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; import io.fabric8.openshift.api.model.Build; import io.fabric8.openshift.api.model.BuildList; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducer.java index 386ee79..5f13231 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducer.java @@ -23,7 +23,6 @@ import io.fabric8.kubernetes.api.model.EditableNamespace; import io.fabric8.kubernetes.api.model.Namespace; import io.fabric8.kubernetes.api.model.NamespaceBuilder; import io.fabric8.kubernetes.api.model.NamespaceList; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducer.java index b674d17..3bfeb87 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducer.java @@ -21,7 +21,6 @@ import java.util.Map; import io.fabric8.kubernetes.api.model.DoneableNode; import io.fabric8.kubernetes.api.model.Node; import io.fabric8.kubernetes.api.model.NodeList; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducer.java index 1c2c01e..049d8d8 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducer.java @@ -24,10 +24,8 @@ import io.fabric8.kubernetes.api.model.PersistentVolumeClaim; import io.fabric8.kubernetes.api.model.PersistentVolumeClaimBuilder; import io.fabric8.kubernetes.api.model.PersistentVolumeClaimList; import io.fabric8.kubernetes.api.model.PersistentVolumeClaimSpec; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; import org.apache.camel.Exchange; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducer.java index 87ac1dc..051b5b1 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducer.java @@ -21,10 +21,8 @@ import java.util.Map; import io.fabric8.kubernetes.api.model.DoneablePersistentVolume; import io.fabric8.kubernetes.api.model.PersistentVolume; import io.fabric8.kubernetes.api.model.PersistentVolumeList; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; import org.apache.camel.Exchange; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducer.java index 16fbf52..b5edb5f 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducer.java @@ -24,10 +24,8 @@ import io.fabric8.kubernetes.api.model.ReplicationController; import io.fabric8.kubernetes.api.model.ReplicationControllerBuilder; import io.fabric8.kubernetes.api.model.ReplicationControllerList; import io.fabric8.kubernetes.api.model.ReplicationControllerSpec; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.kubernetes.client.dsl.ClientRollableScallableResource; import org.apache.camel.Exchange; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducer.java index 9517a90..0c4a89c 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducer.java @@ -24,10 +24,8 @@ import io.fabric8.kubernetes.api.model.ResourceQuota; import io.fabric8.kubernetes.api.model.ResourceQuotaBuilder; import io.fabric8.kubernetes.api.model.ResourceQuotaList; import io.fabric8.kubernetes.api.model.ResourceQuotaSpec; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; import org.apache.camel.Exchange; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducer.java index 86133d9..0006927 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducer.java @@ -21,10 +21,8 @@ import java.util.Map; import io.fabric8.kubernetes.api.model.DoneableSecret; import io.fabric8.kubernetes.api.model.Secret; import io.fabric8.kubernetes.api.model.SecretList; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; import org.apache.camel.Exchange; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducer.java index 521701f..36fa58c 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducer.java @@ -21,10 +21,8 @@ import java.util.Map; import io.fabric8.kubernetes.api.model.DoneableServiceAccount; import io.fabric8.kubernetes.api.model.ServiceAccount; import io.fabric8.kubernetes.api.model.ServiceAccountList; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; import org.apache.camel.Exchange; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducer.java index 1a2733a..ac78c30 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducer.java @@ -24,10 +24,8 @@ import io.fabric8.kubernetes.api.model.Service; import io.fabric8.kubernetes.api.model.ServiceBuilder; import io.fabric8.kubernetes.api.model.ServiceList; import io.fabric8.kubernetes.api.model.ServiceSpec; -import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.dsl.ClientMixedOperation; import io.fabric8.kubernetes.client.dsl.ClientNonNamespaceOperation; -import io.fabric8.kubernetes.client.dsl.ClientOperation; import io.fabric8.kubernetes.client.dsl.ClientResource; import org.apache.camel.Exchange; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java index fb75241..a583e05 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java @@ -89,7 +89,7 @@ public class KubernetesNamespacesConsumerTest extends KubernetesTestSupport { Iterator<Namespace> it = result.iterator(); while (it.hasNext()) { - Namespace namespace = (Namespace) it.next(); + Namespace namespace = it.next(); if ("test".equalsIgnoreCase(namespace.getMetadata().getName())) { testExists = true; } http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducerTest.java index 5e68906..b01038d 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesBuildsProducerTest.java @@ -20,7 +20,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; -import io.fabric8.kubernetes.api.model.PersistentVolume; import io.fabric8.openshift.api.model.Build; import org.apache.camel.Exchange; @@ -28,9 +27,7 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; -import org.junit.Ignore; import org.junit.Test; public class KubernetesBuildsProducerTest extends KubernetesTestSupport { http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java index 21e84d1..8746e36 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNamespacesProducerTest.java @@ -28,7 +28,6 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; @@ -46,7 +45,7 @@ public class KubernetesNamespacesProducerTest extends KubernetesTestSupport { Iterator<Namespace> it = result.iterator(); while (it.hasNext()) { - Namespace namespace = (Namespace) it.next(); + Namespace namespace = it.next(); if ("default".equalsIgnoreCase(namespace.getMetadata().getName())) { defaultExists = true; } @@ -162,7 +161,7 @@ public class KubernetesNamespacesProducerTest extends KubernetesTestSupport { Iterator<Namespace> it = result.iterator(); while (it.hasNext()) { - Namespace namespace = (Namespace) it.next(); + Namespace namespace = it.next(); if ("test".equalsIgnoreCase(namespace.getMetadata().getName())) { testExists = true; } http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java index 6d12321..4bfbce5 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java @@ -17,21 +17,16 @@ package org.apache.camel.component.kubernetes.producer; import java.util.HashMap; -import java.util.Iterator; import java.util.List; import java.util.Map; import io.fabric8.kubernetes.api.model.Node; -import io.fabric8.kubernetes.api.model.PersistentVolume; - import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; -import org.junit.Ignore; import org.junit.Test; public class KubernetesNodesProducerTest extends KubernetesTestSupport { http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java index cc6a4e8..013d76f 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesClaimsProducerTest.java @@ -33,7 +33,6 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; @@ -141,7 +140,7 @@ public class KubernetesPersistentVolumesClaimsProducerTest extends boolean pvcExists = false; Iterator<PersistentVolumeClaim> it = result.iterator(); while (it.hasNext()) { - PersistentVolumeClaim pvcLocal = (PersistentVolumeClaim) it.next(); + PersistentVolumeClaim pvcLocal = it.next(); if ("test".equalsIgnoreCase(pvcLocal.getMetadata().getName())) { pvcExists = true; } http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java index 1ffb9a5..9fcb291 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPersistentVolumesProducerTest.java @@ -27,9 +27,7 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; -import org.junit.Ignore; import org.junit.Test; public class KubernetesPersistentVolumesProducerTest extends KubernetesTestSupport { http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java index 8c3af39..6b9ce4b 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesPodsProducerTest.java @@ -32,7 +32,6 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; @@ -49,7 +48,7 @@ public class KubernetesPodsProducerTest extends KubernetesTestSupport { Iterator<Pod> it = result.iterator(); while (it.hasNext()) { - Pod pod = (Pod) it.next(); + Pod pod = it.next(); if ((pod.getMetadata().getName()).contains("fabric8")) { defaultExists = true; } @@ -82,7 +81,7 @@ public class KubernetesPodsProducerTest extends KubernetesTestSupport { boolean podExists = false; Iterator<Pod> it = result.iterator(); while (it.hasNext()) { - Pod pod = (Pod) it.next(); + Pod pod = it.next(); if (pod.getMetadata().getLabels().containsValue("elasticsearch")) { podExists = true; } http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java index eab26d0..f28d913 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesReplicationControllersProducerTest.java @@ -31,7 +31,6 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; @@ -50,7 +49,7 @@ public class KubernetesReplicationControllersProducerTest extends Iterator<ReplicationController> it = result.iterator(); while (it.hasNext()) { - ReplicationController rc = (ReplicationController) it.next(); + ReplicationController rc = it.next(); if ("fabric8".equalsIgnoreCase(rc.getMetadata().getName())) { fabric8Exists = true; } @@ -85,7 +84,7 @@ public class KubernetesReplicationControllersProducerTest extends boolean rcExists = false; Iterator<ReplicationController> it = result.iterator(); while (it.hasNext()) { - ReplicationController rc = (ReplicationController) it.next(); + ReplicationController rc = it.next(); if ("elasticsearch".equalsIgnoreCase(rc.getMetadata().getName())) { rcExists = true; } http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java index b0fc639..6fd5d5d 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesResourcesQuotaProducerTest.java @@ -29,7 +29,6 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java index 7202513..24d39dc 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesSecretsProducerTest.java @@ -28,7 +28,6 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.apache.commons.codec.binary.Base64; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java index d892f6a..43fce9d 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServiceAccountsProducerTest.java @@ -29,7 +29,6 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.apache.commons.codec.binary.Base64; import org.junit.Test; @@ -48,7 +47,7 @@ public class KubernetesServiceAccountsProducerTest extends KubernetesTestSupport Iterator<ServiceAccount> it = result.iterator(); while (it.hasNext()) { - ServiceAccount service = (ServiceAccount) it.next(); + ServiceAccount service = it.next(); if ("fabric8".equalsIgnoreCase(service.getMetadata().getName())) { fabric8Exists = true; } http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java index 375ab91..443c486 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesServicesProducerTest.java @@ -32,7 +32,6 @@ import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; @@ -50,7 +49,7 @@ public class KubernetesServicesProducerTest extends KubernetesTestSupport { Iterator<Service> it = result.iterator(); while (it.hasNext()) { - Service service = (Service) it.next(); + Service service = it.next(); if ("fabric8".equalsIgnoreCase(service.getMetadata().getName())) { fabric8Exists = true; } @@ -83,7 +82,7 @@ public class KubernetesServicesProducerTest extends KubernetesTestSupport { boolean serviceExists = false; Iterator<Service> it = result.iterator(); while (it.hasNext()) { - Service service = (Service) it.next(); + Service service = it.next(); if ("elasticsearch".equalsIgnoreCase(service.getMetadata() .getName())) { serviceExists = true; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java index daea215..5512a3e 100644 --- a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java +++ b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java @@ -36,8 +36,6 @@ import org.apache.camel.Message; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.impl.DefaultEndpoint; -import org.apache.camel.impl.DefaultExchange; -import org.apache.camel.impl.DefaultMessage; import org.apache.camel.spi.Metadata; import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java index a70e52c..c9ae6eb 100644 --- a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java +++ b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbProducer.java @@ -22,7 +22,6 @@ import java.util.List; import com.mongodb.AggregationOutput; import com.mongodb.BasicDBList; import com.mongodb.BasicDBObject; -import com.mongodb.CommandResult; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; http://git-wip-us.apache.org/repos/asf/camel/blob/ba13226d/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTConfiguration.java b/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTConfiguration.java index a0dcaf1..8047b14 100644 --- a/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTConfiguration.java +++ b/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTConfiguration.java @@ -28,7 +28,6 @@ import org.fusesource.hawtdispatch.DispatchQueue; import org.fusesource.hawtdispatch.transport.TcpTransport; import org.fusesource.mqtt.client.MQTT; import org.fusesource.mqtt.client.QoS; -import org.fusesource.mqtt.client.Tracer; @UriParams public class MQTTConfiguration extends MQTT {
