org.openehealth.ipf.platform.camel.ihe.ws

Class AbstractWsProducer<AuditDatasetType extends WsAuditDataset,ConfigType extends WsTransactionConfiguration<AuditDatasetType>,InType,OutType>

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultProducer

org.openehealth.ipf.platform.camel.ihe.ws.AbstractWsProducer<AuditDatasetType,ConfigType,InType,OutType>

Type Parameters:

InType - type of input data (i.e. of the data got from the route).

OutType - type of output data (i.e. of the data returned to the route).

All Implemented Interfaces:

org.apache.camel.EndpointAware, org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

Direct Known Subclasses:

Hl7v3ContinuationAwareProducer, Iti44Producer, Iti55DeferredResponseProducer, SimpleWsProducer, XdsSubmissionProducer

public abstract class AbstractWsProducer<AuditDatasetType extends WsAuditDataset,ConfigType extends WsTransactionConfiguration<AuditDatasetType>,InType,OutType>
extends org.apache.camel.impl.DefaultProducer

Camel producer used to make calls to a Web Service.

Author:

Jens Riemschneider, Dmytro Rud

Field Summary

Fields inherited from class org.apache.camel.impl.DefaultProducer

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
AbstractWsProducer(AbstractWsEndpoint<AuditDatasetType,ConfigType> endpoint, JaxWsClientFactory<AuditDatasetType> clientFactory, Class<InType> requestClass, Class<OutType> responseClass) Constructs the producer.

Method Summary

Modifier and Type	Method and Description
protected abstract OutType	callService(Object client, InType body) Sends the given request body to a Web Service via the given client proxy.
protected void	cleanRequestContext(org.apache.cxf.jaxws.context.WrappedMessageContext requestContext) Request context is shared among subsequent requests, so we have to clean it.
protected void	configureClient(Object o) Sets thread safety & timeout options of the given CXF client.
protected void	enrichRequestContext(org.apache.camel.Exchange exchange, org.apache.cxf.jaxws.context.WrappedMessageContext requestContext) Enriches the given Web Service request context on the basis of the given Camel exchange, and vice versa.
protected void	enrichResponseMessage(org.apache.camel.Message message, org.apache.cxf.jaxws.context.WrappedMessageContext responseContext) Enriches the given response message from the Web Service request context data.
protected String[]	getAlternativeRequestKeys(org.apache.camel.Exchange exchange) Determines the set of correlation keys for the request message contained in the given exchange, which are alternative to the WS-Addressing message ID.
protected Object	getClient() Retrieves the client stub for the Web Service.
AbstractWsEndpoint<AuditDatasetType,ConfigType>	getEndpoint()
Class<InType>	getRequestClass()
Class<OutType>	getResponseClass()
WsTransactionConfiguration	getWsTransactionConfiguration()
void	process(org.apache.camel.Exchange exchange)

Methods inherited from class org.apache.camel.impl.DefaultProducer

createExchange, createExchange, createExchange, doStart, doStop, isSingleton, toString

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

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, 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.Service

start, stop

Constructor Detail

AbstractWsProducer

public AbstractWsProducer(AbstractWsEndpoint<AuditDatasetType,ConfigType> endpoint,
                          JaxWsClientFactory<AuditDatasetType> clientFactory,
                          Class<InType> requestClass,
                          Class<OutType> responseClass)

Constructs the producer.

Parameters:

endpoint - the endpoint that creates this producer.

clientFactory - the factory for clients to produce messages for the service.

requestClass - type of request messages.

Method Detail

process

public void process(org.apache.camel.Exchange exchange)
             throws Exception

Throws:

Exception

callService

protected abstract OutType callService(Object client,
                                       InType body)
                                throws Exception

Sends the given request body to a Web Service via the given client proxy.

Throws:

Exception

enrichRequestContext

protected void enrichRequestContext(org.apache.camel.Exchange exchange,
                                    org.apache.cxf.jaxws.context.WrappedMessageContext requestContext)

Enriches the given Web Service request context on the basis of the given Camel exchange, and vice versa.

getAlternativeRequestKeys

protected String[] getAlternativeRequestKeys(org.apache.camel.Exchange exchange)

Determines the set of correlation keys for the request message contained in the given exchange, which are alternative to the WS-Addressing message ID. An example of alternative key is the query ID in HL7v3-based transactions.

Per default, this method returns null.

Parameters:

exchange - Camel exchange containing a request message.

Returns:

A non-empty collection of non-null alternative keys, or null, when no keys could have been extracted.

enrichResponseMessage

protected void enrichResponseMessage(org.apache.camel.Message message,
                                     org.apache.cxf.jaxws.context.WrappedMessageContext responseContext)

Enriches the given response message from the Web Service request context data.

getEndpoint

public AbstractWsEndpoint<AuditDatasetType,ConfigType> getEndpoint()

Specified by:

getEndpoint in interface org.apache.camel.EndpointAware

Overrides:

getEndpoint in class org.apache.camel.impl.DefaultProducer

configureClient

protected void configureClient(Object o)

Sets thread safety & timeout options of the given CXF client.

cleanRequestContext

protected void cleanRequestContext(org.apache.cxf.jaxws.context.WrappedMessageContext requestContext)

Request context is shared among subsequent requests, so we have to clean it.

getClient

protected Object getClient()

Retrieves the client stub for the Web Service.

This method caches the client stub instance and therefore requires thread synchronization.

Returns:

the client stub.

getWsTransactionConfiguration

public WsTransactionConfiguration getWsTransactionConfiguration()

Returns:

the info describing the Web Service.

getRequestClass

public Class<InType> getRequestClass()

getResponseClass

public Class<OutType> getResponseClass()