You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/09/12 06:17:53 UTC
[camel-quarkus] branch master updated: Fixed CS for Paho extension
and integration test
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-quarkus.git
The following commit(s) were added to refs/heads/master by this push:
new 2128879 Fixed CS for Paho extension and integration test
2128879 is described below
commit 212887909b4509b99abe77860d833670935e85d9
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Sep 12 08:17:30 2019 +0200
Fixed CS for Paho extension and integration test
---
.../component/paho/deployment/PahoProcessor.java | 21 +++++++++++----------
.../quarkus/component/paho/it/PahoResource.java | 8 ++++----
.../component/paho/it/ActiveMQTestResource.java | 8 ++++----
3 files changed, 19 insertions(+), 18 deletions(-)
diff --git a/extensions/paho/deployment/src/main/java/org/apache/camel/quarkus/component/paho/deployment/PahoProcessor.java b/extensions/paho/deployment/src/main/java/org/apache/camel/quarkus/component/paho/deployment/PahoProcessor.java
index 14af793..eaac4e8 100644
--- a/extensions/paho/deployment/src/main/java/org/apache/camel/quarkus/component/paho/deployment/PahoProcessor.java
+++ b/extensions/paho/deployment/src/main/java/org/apache/camel/quarkus/component/paho/deployment/PahoProcessor.java
@@ -16,6 +16,11 @@
*/
package org.apache.camel.quarkus.component.paho.deployment;
+import java.util.Arrays;
+import java.util.List;
+
+import javax.inject.Inject;
+
import io.quarkus.deployment.annotations.BuildProducer;
import io.quarkus.deployment.annotations.BuildStep;
import io.quarkus.deployment.builditem.FeatureBuildItem;
@@ -27,26 +32,22 @@ import org.eclipse.paho.client.mqttv3.internal.TCPNetworkModuleFactory;
import org.eclipse.paho.client.mqttv3.logging.JSR47Logger;
import org.eclipse.paho.client.mqttv3.spi.NetworkModuleFactory;
-import javax.inject.Inject;
-import java.util.Arrays;
-import java.util.List;
-
class PahoProcessor {
private static final String FEATURE = "camel-paho";
- @Inject
- BuildProducer<SubstrateResourceBuildItem> resource;
-
- @Inject
- BuildProducer<SubstrateResourceBundleBuildItem> resourceBundle;
-
private static final List<Class<?>> PAHO_REFLECTIVE_CLASSES = Arrays.asList(
JSR47Logger.class,
TCPNetworkModuleFactory.class,
SSLNetworkModuleFactory.class
);
+ @Inject
+ BuildProducer<SubstrateResourceBuildItem> resource;
+
+ @Inject
+ BuildProducer<SubstrateResourceBundleBuildItem> resourceBundle;
+
@BuildStep
FeatureBuildItem feature() {
return new FeatureBuildItem(FEATURE);
diff --git a/integration-tests/paho/src/main/java/org/apache/camel/quarkus/component/paho/it/PahoResource.java b/integration-tests/paho/src/main/java/org/apache/camel/quarkus/component/paho/it/PahoResource.java
index a9cb51d..d383ddb 100644
--- a/integration-tests/paho/src/main/java/org/apache/camel/quarkus/component/paho/it/PahoResource.java
+++ b/integration-tests/paho/src/main/java/org/apache/camel/quarkus/component/paho/it/PahoResource.java
@@ -16,10 +16,6 @@
*/
package org.apache.camel.quarkus.component.paho.it;
-import org.apache.camel.ConsumerTemplate;
-import org.apache.camel.ProducerTemplate;
-import org.jboss.logging.Logger;
-
import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;
import javax.ws.rs.Consumes;
@@ -30,6 +26,10 @@ import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
+import org.apache.camel.ConsumerTemplate;
+import org.apache.camel.ProducerTemplate;
+import org.jboss.logging.Logger;
+
@Path("/paho")
@ApplicationScoped
public class PahoResource {
diff --git a/integration-tests/paho/src/test/java/org/apache/camel/quarkus/component/paho/it/ActiveMQTestResource.java b/integration-tests/paho/src/test/java/org/apache/camel/quarkus/component/paho/it/ActiveMQTestResource.java
index 0dd6ac0..7c1a6a8 100644
--- a/integration-tests/paho/src/test/java/org/apache/camel/quarkus/component/paho/it/ActiveMQTestResource.java
+++ b/integration-tests/paho/src/test/java/org/apache/camel/quarkus/component/paho/it/ActiveMQTestResource.java
@@ -17,14 +17,14 @@
package org.apache.camel.quarkus.component.paho.it;
-import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
-import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.broker.TransportConnector;
-
import java.net.URI;
import java.util.Collections;
import java.util.Map;
+import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.TransportConnector;
+
public class ActiveMQTestResource implements QuarkusTestResourceLifecycleManager {
private BrokerService broker;