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

Class AbstractWsEndpoint<AuditDatasetType extends WsAuditDataset,ConfigType extends WsTransactionConfiguration<AuditDatasetType>>

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.openehealth.ipf.platform.camel.ihe.ws.AbstractWsEndpoint<AuditDatasetType,ConfigType>

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService, AuditableEndpoint<AuditDatasetType>

Direct Known Subclasses:

Hl7v3AsyncResponseEndpoint, Hl7v3Endpoint, HpdEndpoint, SimpleHl7v2WsEndpoint, XdsAsyncResponseEndpoint, XdsEndpoint

@ManagedResource(description="Managed IPF eHealth Web Service Endpoint")
public abstract class AbstractWsEndpoint<AuditDatasetType extends WsAuditDataset,ConfigType extends WsTransactionConfiguration<AuditDatasetType>>
extends org.apache.camel.impl.DefaultEndpoint
implements AuditableEndpoint<AuditDatasetType>

Camel endpoint used to create producers and consumers based on webservice calls.

Author:

Jens Riemschneider, Dmytro Rud

Field Summary

Fields

Modifier and Type	Field and Description
static String	CORRELATION_KEY_HEADER_NAME Name of Camel message header where the user should store the optional correlation key.
static String	INCOMING_HTTP_HEADERS Name of Camel message header where incoming HTTP headers will be stored as a Map<String, String>.
static String	INCOMING_SOAP_HEADERS Name of Camel message header where incoming SOAP headers will be stored as a Map<QName, Header>.
static String	OUTGOING_HTTP_HEADERS Name of Camel message header from where additional user-defined HTTP headers will be taken as a Map<String, String>.
static String	OUTGOING_SOAP_HEADERS Name of Camel message header from where additional user-defined HTTP headers will be taken as a List<Header> or Map<QName, Header>.
static String	WSA_REPLYTO_HEADER_NAME Name of incoming Camel header where the user should store the URL of asynchronous response endpoint (WS-Addressing header "ReplyTo").

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

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractWsEndpoint(String endpointUri, String address, AbstractWsComponent<AuditDatasetType,ConfigType,? extends WsInteractionId<ConfigType>> component, AuditContext auditContext, org.apache.cxf.interceptor.InterceptorProvider customInterceptors, List<org.apache.cxf.feature.AbstractFeature> features, List<String> schemaLocations, Map<String,Object> properties, Class<? extends AbstractWebService> serviceClass) Constructs the endpoint.
protected	AbstractWsEndpoint(String endpointUri, String address, AbstractWsComponent<AuditDatasetType,ConfigType,? extends WsInteractionId<ConfigType>> component, Map<String,Object> parameters, Class<? extends AbstractWebService> serviceClass)

Method Summary

Modifier and Type	Method and Description
org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
AuditContext	getAuditContext()
AuditStrategy<AuditDatasetType>	getClientAuditStrategy() Returns client-side audit strategy instance.
AbstractWsComponent<AuditDatasetType,ConfigType,? extends WsInteractionId>	getComponent()
AsynchronyCorrelator<AuditDatasetType>	getCorrelator() Returns the correlator.
org.apache.cxf.interceptor.InterceptorProvider	getCustomInterceptors() Returns custom interceptors configured for this endpoint.
protected AbstractWebService	getCustomServiceInstance(AbstractWsEndpoint<AuditDatasetType,ConfigType> endpoint) Returns a new instance of a service class.
List<org.apache.cxf.feature.AbstractFeature>	getFeatures()
String	getHomeCommunityId()
HostnameVerifier	getHostnameVerifier()
abstract JaxWsClientFactory<AuditDatasetType>	getJaxWsClientFactory()
abstract JaxWsServiceFactory<AuditDatasetType>	getJaxWsServiceFactory()
String	getPassword()
abstract AbstractWsProducer<AuditDatasetType,ConfigType,?,?>	getProducer(AbstractWsEndpoint<AuditDatasetType,ConfigType> endpoint, JaxWsClientFactory<AuditDatasetType> clientFactory) Constructs and returns a transaction-specific Camel producer instance
Map<String,Object>	getProperties()
WsRejectionHandlingStrategy	getRejectionHandlingStrategy()
List<String>	getSchemaLocations()
AuditStrategy<AuditDatasetType>	getServerAuditStrategy() Returns server-side audit strategy instance.
String	getServiceAddress() Returns the address of the service.
AbstractWebService	getServiceInstance() Constructs and returns a transaction-specific service class instance for the given endpoint.
String	getServiceUrl() Returns the URL of the service.
org.apache.camel.util.jsse.SSLContextParameters	getSslContextParameters()
String	getUsername()
boolean	isAddressing()
boolean	isAudit()
boolean	isMtom()
boolean	isSecure()
boolean	isSingleton()
boolean	isSwaOutSupport()
void	setAudit(boolean audit)
void	setAuditContext(AuditContext auditContext)
void	setCorrelator(AsynchronyCorrelator<AuditDatasetType> correlator) Configures the asynchrony correlator for this endpoint.
void	setHomeCommunityId(String homeCommunityId) Configures homeCommunityId for this endpoint.
void	setHomeCommunityId(URN urn) Configures homeCommunityId for this endpoint.
void	setHostnameVerifier(HostnameVerifier hostnameVerifier)
void	setPassword(String password)
void	setRejectionHandlingStrategy(WsRejectionHandlingStrategy rejectionHandlingStrategy)
void	setSecure(boolean secure)
void	setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
void	setUsername(String username)

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

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, 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, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Endpoint

configureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointConfiguration, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContext

Methods inherited from interface org.apache.camel.Service

start, stop

Field Detail

WSA_REPLYTO_HEADER_NAME

public static final String WSA_REPLYTO_HEADER_NAME

Name of incoming Camel header where the user should store the URL of asynchronous response endpoint (WS-Addressing header "ReplyTo").

CORRELATION_KEY_HEADER_NAME

public static final String CORRELATION_KEY_HEADER_NAME

Name of Camel message header where the user should store the optional correlation key.

INCOMING_HTTP_HEADERS

public static final String INCOMING_HTTP_HEADERS

Name of Camel message header where incoming HTTP headers will be stored as a Map<String, String>.

OUTGOING_HTTP_HEADERS

public static final String OUTGOING_HTTP_HEADERS

Name of Camel message header from where additional user-defined HTTP headers will be taken as a Map<String, String>.

INCOMING_SOAP_HEADERS

public static final String INCOMING_SOAP_HEADERS

Name of Camel message header where incoming SOAP headers will be stored as a Map<QName, Header>.

OUTGOING_SOAP_HEADERS

public static final String OUTGOING_SOAP_HEADERS

Name of Camel message header from where additional user-defined HTTP headers will be taken as a List<Header> or Map<QName, Header>.

Constructor Detail

AbstractWsEndpoint

protected AbstractWsEndpoint(String endpointUri,
                             String address,
                             AbstractWsComponent<AuditDatasetType,ConfigType,? extends WsInteractionId<ConfigType>> component,
                             Map<String,Object> parameters,
                             Class<? extends AbstractWebService> serviceClass)

AbstractWsEndpoint

protected AbstractWsEndpoint(String endpointUri,
                             String address,
                             AbstractWsComponent<AuditDatasetType,ConfigType,? extends WsInteractionId<ConfigType>> component,
                             AuditContext auditContext,
                             org.apache.cxf.interceptor.InterceptorProvider customInterceptors,
                             List<org.apache.cxf.feature.AbstractFeature> features,
                             List<String> schemaLocations,
                             Map<String,Object> properties,
                             Class<? extends AbstractWebService> serviceClass)

Constructs the endpoint.

Parameters:

endpointUri - the URI of the endpoint.

address - the endpoint address from the URI.

component - the component creating this endpoint.

auditContext - the audit context

customInterceptors - user-defined set of additional CXF interceptors.

features - user-defined list of CXF features.

Method Detail

getServiceInstance

public AbstractWebService getServiceInstance()

Constructs and returns a transaction-specific service class instance for the given endpoint.

Returns:

service class instance for the given endpoint.

getCustomServiceInstance

protected AbstractWebService getCustomServiceInstance(AbstractWsEndpoint<AuditDatasetType,ConfigType> endpoint)

Returns a new instance of a service class. Overwrite this method if a simple call to Class.newInstance() is not sufficient.

Parameters:

endpoint - this endpoint as paramater

Returns:

service class instance

getClientAuditStrategy

public AuditStrategy<AuditDatasetType> getClientAuditStrategy()

Description copied from interface: AuditableEndpoint

Returns client-side audit strategy instance.

Specified by:

getClientAuditStrategy in interface AuditableEndpoint<AuditDatasetType extends WsAuditDataset>

Returns:

client-side audit strategy instance

getServerAuditStrategy

public AuditStrategy<AuditDatasetType> getServerAuditStrategy()

Description copied from interface: AuditableEndpoint

Returns server-side audit strategy instance.

Specified by:

getServerAuditStrategy in interface AuditableEndpoint<AuditDatasetType extends WsAuditDataset>

Returns:

server-side audit strategy instance

isSingleton

@ManagedAttribute
public boolean isSingleton()

Specified by:

isSingleton in interface org.apache.camel.IsSingleton

getServiceUrl

public String getServiceUrl()

Returns the URL of the service.

The URL is derived from the endpoint URI defined in the constructor. If the URI does not represent a producer, this method throws an exception.

Returns:

the service URL.

getServiceAddress

@ManagedAttribute(description="Service Address")
public String getServiceAddress()

Returns the address of the service.

The address is derived from the endpoint URI defined in the constructor. If the URI does not represent a consumer, this method throws an exception.

Returns:

the service address.

isAudit

@ManagedAttribute(description="Audit Enabled")
public boolean isAudit()

Specified by:

isAudit in interface AuditableEndpoint<AuditDatasetType extends WsAuditDataset>

Returns:

true if auditing is turned on. true by default.

setAudit

public void setAudit(boolean audit)

Parameters:

audit - true if auditing shall be turned on.

getAuditContext

public AuditContext getAuditContext()

Specified by:

getAuditContext in interface AuditableEndpoint<AuditDatasetType extends WsAuditDataset>

Returns:

audit context to be used for this endpoint

setAuditContext

public void setAuditContext(AuditContext auditContext)

isSecure

@ManagedAttribute(description="Security Enabled")
public boolean isSecure()

Returns:

true if https should be used instead of http. Defaults to false.

setSecure

public void setSecure(boolean secure)

Parameters:

secure - true if https should be used instead of http.

getUsername

public String getUsername()

setUsername

@ManagedAttribute(description="Basic Authentication Username")
public void setUsername(String username)

getPassword

@ManagedAttribute(description="Basic Authentication Password")
public String getPassword()

setPassword

public void setPassword(String password)

getSslContextParameters

public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()

setSslContextParameters

public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)

getHostnameVerifier

public HostnameVerifier getHostnameVerifier()

setHostnameVerifier

public void setHostnameVerifier(HostnameVerifier hostnameVerifier)

setCorrelator

public void setCorrelator(AsynchronyCorrelator<AuditDatasetType> correlator)

Configures the asynchrony correlator for this endpoint.

getCorrelator

public AsynchronyCorrelator<AuditDatasetType> getCorrelator()

Returns the correlator.

getCustomInterceptors

public org.apache.cxf.interceptor.InterceptorProvider getCustomInterceptors()

Returns custom interceptors configured for this endpoint.

getHomeCommunityId

@ManagedAttribute(description="HomeCommunityId")
public String getHomeCommunityId()

Returns:

homeCommunityId of this endpoint.

setHomeCommunityId

public void setHomeCommunityId(String homeCommunityId)

Configures homeCommunityId for this endpoint.

Parameters:

homeCommunityId - homeCommunityId in format "urn:oid:1.2.3.4.5".

setHomeCommunityId

public void setHomeCommunityId(URN urn)

Configures homeCommunityId for this endpoint.

Parameters:

urn - homeCommunityId in format "urn:oid:1.2.3.4.5".

getRejectionHandlingStrategy

public WsRejectionHandlingStrategy getRejectionHandlingStrategy()

Returns:

rejection handling strategy, if any configured.

setRejectionHandlingStrategy

public void setRejectionHandlingStrategy(WsRejectionHandlingStrategy rejectionHandlingStrategy)

Parameters:

rejectionHandlingStrategy - a rejection handling strategy instance.

getFeatures

public List<org.apache.cxf.feature.AbstractFeature> getFeatures()

Returns:

CXF features configured for this endpoint.

getSchemaLocations

public List<String> getSchemaLocations()

Returns:

CXF schema locations configured for this endpoint.

getProperties

public Map<String,Object> getProperties()

Returns:

CXF schema locations configured for this endpoint.

getComponent

public AbstractWsComponent<AuditDatasetType,ConfigType,? extends WsInteractionId> getComponent()

Overrides:

getComponent in class org.apache.camel.impl.DefaultEndpoint

getJaxWsClientFactory

public abstract JaxWsClientFactory<AuditDatasetType> getJaxWsClientFactory()

Returns:

JAX-WS client object factory.

getJaxWsServiceFactory

public abstract JaxWsServiceFactory<AuditDatasetType> getJaxWsServiceFactory()

Returns:

JAX-WS service object factory.

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws org.apache.cxf.common.i18n.Exception

Specified by:

createConsumer in interface org.apache.camel.Endpoint

Throws:

org.apache.cxf.common.i18n.Exception

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Specified by:

createProducer in interface org.apache.camel.Endpoint

Throws:

Exception

getProducer

public abstract AbstractWsProducer<AuditDatasetType,ConfigType,?,?> getProducer(AbstractWsEndpoint<AuditDatasetType,ConfigType> endpoint,
                                                                                JaxWsClientFactory<AuditDatasetType> clientFactory)

Constructs and returns a transaction-specific Camel producer instance

Parameters:

clientFactory - JAX-WS client factory instance.

Returns:

Camel producer instance.

Since:

3.1

isAddressing

@ManagedAttribute(description="Addressing Enabled")
public boolean isAddressing()

Returns:

true if WS-Addressing enabled.

isMtom

@ManagedAttribute(description="Mtom Enabled")
public boolean isMtom()

Returns:

true if MTOM enabled.

isSwaOutSupport

@ManagedAttribute(description="SOAP With Attachments Output Enabled")
public boolean isSwaOutSupport()

Returns:

true if SOAP With Attachments Output enabled.