Package org.apache.camel.component.platform.http.springboot

Class SpringBootPlatformHttpConsumer

java.lang.Object
org.apache.camel.support.service.BaseService
org.apache.camel.support.service.ServiceSupport
org.apache.camel.support.DefaultConsumer
org.apache.camel.component.platform.http.springboot.SpringBootPlatformHttpConsumer
All Implemented Interfaces:
AutoCloseable, org.apache.camel.component.platform.http.spi.PlatformHttpConsumer, org.apache.camel.Consumer, org.apache.camel.EndpointAware, org.apache.camel.health.HealthCheckAware, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HostedService, org.apache.camel.spi.RouteIdAware, org.apache.camel.StatefulService, org.apache.camel.Suspendable, org.apache.camel.SuspendableService
public class SpringBootPlatformHttpConsumer extends org.apache.camel.support.DefaultConsumer implements org.apache.camel.component.platform.http.spi.PlatformHttpConsumer, org.apache.camel.Suspendable, org.apache.camel.SuspendableService

  • Field Summary

    Fields inherited from class org.apache.camel.support.service.BaseService

    BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING

  • Constructor Summary

    Constructors
    Constructor
    Description
    SpringBootPlatformHttpConsumer(org.apache.camel.component.platform.http.PlatformHttpEndpoint endpoint, org.apache.camel.Processor processor)
     
    SpringBootPlatformHttpConsumer(org.apache.camel.component.platform.http.PlatformHttpEndpoint endpoint, org.apache.camel.Processor processor, Executor executor)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    afterProcess(jakarta.servlet.http.HttpServletResponse response, org.apache.camel.Exchange exchange)
     
    org.apache.camel.component.platform.http.PlatformHttpEndpoint
    getEndpoint()
     
    protected void
    handleService(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response)
     
    CompletableFuture<Void>
    service(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response)
    This method is invoked by Spring Boot when invoking Camel via platform-http.

    Methods inherited from class org.apache.camel.support.DefaultConsumer

    createExchange, createUoW, defaultConsumerCallback, doBuild, doInit, doneUoW, doShutdown, doStart, doStop, getAsyncProcessor, getExceptionHandler, getHealthCheck, getProcessor, getRoute, getRouteId, handleException, handleException, handleException, isHostedService, releaseExchange, setExceptionHandler, setHealthCheck, setRoute, setRouteId, toString

    Methods inherited from class org.apache.camel.support.service.BaseService

    build, doFail, doLifecycleChange, doResume, doSuspend, fail, getInternalLock, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    Methods inherited from interface org.apache.camel.Consumer

    createExchange, defaultConsumerCallback, getProcessor, releaseExchange

    Methods inherited from interface org.apache.camel.Service

    build, close, init, start, stop

    Methods inherited from interface org.apache.camel.ShutdownableService

    shutdown

    Methods inherited from interface org.apache.camel.StatefulService

    getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending

    Methods inherited from interface org.apache.camel.SuspendableService

    isSuspended, resume, suspend

  • Constructor Details

    • SpringBootPlatformHttpConsumer

      public SpringBootPlatformHttpConsumer(org.apache.camel.component.platform.http.PlatformHttpEndpoint endpoint, org.apache.camel.Processor processor)

    • SpringBootPlatformHttpConsumer

      public SpringBootPlatformHttpConsumer(org.apache.camel.component.platform.http.PlatformHttpEndpoint endpoint, org.apache.camel.Processor processor, Executor executor)

  • Method Details

    • getEndpoint

      public org.apache.camel.component.platform.http.PlatformHttpEndpoint getEndpoint()
      Specified by:
      getEndpoint in interface org.apache.camel.EndpointAware
      Specified by:
      getEndpoint in interface org.apache.camel.component.platform.http.spi.PlatformHttpConsumer
      Overrides:
      getEndpoint in class org.apache.camel.support.DefaultConsumer

    • service

      @ResponseBody public CompletableFuture<Void> service(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response)
      This method is invoked by Spring Boot when invoking Camel via platform-http. The method is already running asynchronously via AsyncExecutionInterceptor. Returns an empty CompletableFuture as per documentation https://spring.io/guides/gs/async-method

    • handleService

      protected void handleService(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response) throws Exception
      Throws:
      Exception

    • afterProcess

      protected void afterProcess(jakarta.servlet.http.HttpServletResponse response, org.apache.camel.Exchange exchange) throws Exception
      Throws:
      Exception