[camel] 02/02: Fixed CS and make platform-http create consumer in doInit instead of doStart

[davsclaus]

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

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

commit 8be2135df6cff9074dee31fe65ce17ada175491d
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Mar 31 10:15:12 2020 +0200

    Fixed CS and make platform-http create consumer in doInit instead of doStart
---
 .../platform/http/PlatformHttpEndpoint.java        | 27 ++++++++++------------
 1 file changed, 12 insertions(+), 15 deletions(-)

diff --git 
a/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/PlatformHttpEndpoint.java
 
b/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/PlatformHttpEndpoint.java
index ff46508..b3b721a 100644
--- 
a/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/PlatformHttpEndpoint.java
+++ 
b/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/PlatformHttpEndpoint.java
@@ -31,12 +31,9 @@ import org.apache.camel.spi.UriPath;
 import org.apache.camel.support.DefaultConsumer;
 import org.apache.camel.support.DefaultEndpoint;
 import org.apache.camel.support.service.ServiceHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 @UriEndpoint(firstVersion = "3.0.0", scheme = "platform-http", title = 
"Platform HTTP", syntax = "platform-http:path", label = "http", consumerOnly = 
true)
 public class PlatformHttpEndpoint extends DefaultEndpoint implements 
AsyncEndpoint, HeaderFilterStrategyAware {
-    private static final Logger LOGGER = 
LoggerFactory.getLogger(PlatformHttpEndpoint.class);
 
     @UriPath(description = "The path under which this endpoint serves the HTTP 
requests")
     @Metadata(required = true)
@@ -86,38 +83,38 @@ public class PlatformHttpEndpoint extends DefaultEndpoint 
implements AsyncEndpoi
             private Consumer delegatedConsumer;
 
             @Override
-            public PlatformHttpEndpoint getEndpoint () {
+            public PlatformHttpEndpoint getEndpoint() {
                 return (PlatformHttpEndpoint) super.getEndpoint();
             }
 
             @Override
-            protected void doStart () throws Exception {
-                super.doStart();
-
+            protected void doInit() throws Exception {
+                super.doInit();
                 delegatedConsumer = 
getEndpoint().getOrCreateEngine().createConsumer(getEndpoint(), getProcessor());
                 configureConsumer(delegatedConsumer);
+            }
 
+            @Override
+            protected void doStart() throws Exception {
+                super.doStart();
                 ServiceHelper.startService(delegatedConsumer);
             }
 
             @Override
-            protected void doStop () throws Exception {
+            protected void doStop() throws Exception {
                 super.doStop();
-
                 ServiceHelper.stopAndShutdownServices(delegatedConsumer);
             }
 
             @Override
-            protected void doResume () throws Exception {
+            protected void doResume() throws Exception {
                 ServiceHelper.resumeService(delegatedConsumer);
-
                 super.doResume();
             }
 
             @Override
-            protected void doSuspend () throws Exception {
+            protected void doSuspend() throws Exception {
                 ServiceHelper.suspendService(delegatedConsumer);
-
                 super.doSuspend();
             }
         };
@@ -187,7 +184,7 @@ public class PlatformHttpEndpoint extends DefaultEndpoint 
implements AsyncEndpoi
 
     PlatformHttpEngine getOrCreateEngine() {
         return platformHttpEngine != null
-            ? platformHttpEngine
-            : ((PlatformHttpComponent)getComponent()).getOrCreateEngine();
+                ? platformHttpEngine
+                : ((PlatformHttpComponent) getComponent()).getOrCreateEngine();
     }
 }