Class DefaultWsConsumer<AuditDatasetType extends WsAuditDataset,​ConfigType extends WsTransactionConfiguration<AuditDatasetType>>

  • All Implemented Interfaces:
    AutoCloseable, org.apache.camel.Consumer, org.apache.camel.EndpointAware, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.RouteIdAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

    public class DefaultWsConsumer<AuditDatasetType extends WsAuditDataset,​ConfigType extends WsTransactionConfiguration<AuditDatasetType>>
    extends org.apache.camel.support.DefaultConsumer
    Camel component used to create process incoming exchanges based on webservice calls.
    Author:
    Jens Riemschneider, Dmytro Rud
    • 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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void doStart()  
      protected void doStop()  
      AbstractWsEndpoint<AuditDatasetType,​ConfigType> getEndpoint()  
      void process​(org.apache.camel.Exchange exchange)
      Processes an exchange with the processor configured in the constructor.
      • Methods inherited from class org.apache.camel.support.DefaultConsumer

        createUoW, doInit, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, getRouteId, handleException, handleException, setExceptionHandler, setRoute, setRouteId, toString
      • Methods inherited from class org.apache.camel.support.service.BaseService

        build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
      • 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 Detail

      • DefaultWsConsumer

        public DefaultWsConsumer​(AbstractWsEndpoint<AuditDatasetType,​ConfigType> endpoint,
                                 org.apache.camel.Processor processor,
                                 AbstractWebService service,
                                 Server server)
        Constructs the consumer.
        Parameters:
        endpoint - the endpoint representation in Camel.
        processor - the processor to start processing incoming exchanges.
        service - the service to consume messages from.
        server - the CXF server instance driving the service.
    • Method Detail

      • getEndpoint

        public AbstractWsEndpoint<AuditDatasetType,​ConfigType> getEndpoint()
        Specified by:
        getEndpoint in interface org.apache.camel.EndpointAware
        Overrides:
        getEndpoint in class org.apache.camel.support.DefaultConsumer
      • process

        public void process​(org.apache.camel.Exchange exchange)
        Processes an exchange with the processor configured in the constructor.
        Parameters:
        exchange - the exchange to process.
      • doStop

        protected void doStop()
                       throws Exception
        Overrides:
        doStop in class org.apache.camel.support.DefaultConsumer
        Throws:
        Exception
      • doStart

        protected void doStart()
                        throws Exception
        Overrides:
        doStart in class org.apache.camel.support.DefaultConsumer
        Throws:
        Exception