public class DefaultWsConsumer<AuditDatasetType extends WsAuditDataset,ConfigType extends WsTransactionConfiguration<AuditDatasetType>>
extends org.apache.camel.impl.DefaultConsumer
Constructor and Description |
---|
DefaultWsConsumer(AbstractWsEndpoint<AuditDatasetType,ConfigType> endpoint,
org.apache.camel.Processor processor,
AbstractWebService service,
org.apache.cxf.endpoint.Server server)
Constructs the consumer.
|
Modifier and Type | Method and 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.
|
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public DefaultWsConsumer(AbstractWsEndpoint<AuditDatasetType,ConfigType> endpoint, org.apache.camel.Processor processor, AbstractWebService service, org.apache.cxf.endpoint.Server server)
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.public AbstractWsEndpoint<AuditDatasetType,ConfigType> getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
public void process(org.apache.camel.Exchange exchange)
exchange
- the exchange to process.protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
Copyright © 2018 Open eHealth Foundation. All rights reserved.