org.openehealth.ipf.platform.camel.ihe.fhir.core

Class FhirEndpoint<AuditDatasetType extends FhirAuditDataset,ComponentType extends FhirComponent<AuditDatasetType>>

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.openehealth.ipf.platform.camel.ihe.fhir.core.FhirEndpoint<AuditDatasetType,ComponentType>

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>, InterceptableEndpoint<FhirEndpointConfiguration<AuditDatasetType>,ComponentType>

Direct Known Subclasses:

CustomFhirEndpoint, Iti65Endpoint, Iti66Endpoint, Iti67Endpoint, Iti78Endpoint, Iti81Endpoint, Iti83Endpoint, Pcc44Endpoint

public abstract class FhirEndpoint<AuditDatasetType extends FhirAuditDataset,ComponentType extends FhirComponent<AuditDatasetType>>
extends org.apache.camel.impl.DefaultEndpoint
implements InterceptableEndpoint<FhirEndpointConfiguration<AuditDatasetType>,ComponentType>, AuditableEndpoint<AuditDatasetType>

Generic FHIR endpoint

Since:

3.1

Author:

Christian Ohr

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
FhirEndpoint(String uri, ComponentType fhirComponent, FhirEndpointConfiguration<AuditDatasetType> config)

Method Summary

Modifier and Type	Method and Description
void	connect(FhirConsumer<AuditDatasetType> consumer) Called when a FhirConsumer is started.
List<Interceptor>	createInitialConsumerInterceptorChain() Returns a list of interceptors that are default for FHIR consumers.
List<Interceptor>	createInitialProducerInterceptorChain() Returns a list of interceptors that are default for FHIR producers.
void	disconnect(FhirConsumer<AuditDatasetType> consumer) Called when a FhirConsumer is stopped.
org.apache.camel.Consumer	doCreateConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	doCreateProducer()
AuditContext	getAuditContext()
AuditStrategy<AuditDatasetType>	getClientAuditStrategy() Returns client-side audit strategy instance.
ClientRequestFactory<?>	getClientRequestFactory()
ca.uhn.fhir.context.FhirContext	getContext()
ComponentType	getInterceptableComponent()
FhirEndpointConfiguration<AuditDatasetType>	getInterceptableConfiguration()
AuditStrategy<AuditDatasetType>	getServerAuditStrategy() Returns server-side audit strategy instance.
boolean	isSingleton()

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

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, 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.openehealth.ipf.platform.camel.ihe.core.InterceptableEndpoint

createConsumer, createProducer, getCustomInterceptors

Methods inherited from interface org.openehealth.ipf.platform.camel.ihe.atna.AuditableEndpoint

isAudit

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

Constructor Detail

FhirEndpoint

public FhirEndpoint(String uri,
                    ComponentType fhirComponent,
                    FhirEndpointConfiguration<AuditDatasetType> config)

Method Detail

getInterceptableComponent

public ComponentType getInterceptableComponent()

Specified by:

getInterceptableComponent in interface InterceptableEndpoint<FhirEndpointConfiguration<AuditDatasetType extends FhirAuditDataset>,ComponentType extends FhirComponent<AuditDatasetType>>

Returns:

the component for this endpoint

doCreateProducer

public org.apache.camel.Producer doCreateProducer()

Specified by:

doCreateProducer in interface InterceptableEndpoint<FhirEndpointConfiguration<AuditDatasetType extends FhirAuditDataset>,ComponentType extends FhirComponent<AuditDatasetType>>

Returns:

the actual producer without any interceptors configured

connect

public void connect(FhirConsumer<AuditDatasetType> consumer)
             throws Exception

Called when a FhirConsumer is started. Registers the resource provider

Parameters:

consumer - FhirConsumer

Throws:

Exception - if resource provider could not be registered

disconnect

public void disconnect(FhirConsumer<AuditDatasetType> consumer)
                throws Exception

Called when a FhirConsumer is stopped. Unregisters the resource provider

Parameters:

consumer - FhirConsumer

Throws:

Exception - if resource provider could not be unregistered

getContext

public ca.uhn.fhir.context.FhirContext getContext()

createInitialConsumerInterceptorChain

public List<Interceptor> createInitialConsumerInterceptorChain()

Returns a list of interceptors that are default for FHIR consumers. Subclasses can add additional interceptors that are required for a concrete FHIR endpoint.

Specified by:

createInitialConsumerInterceptorChain in interface InterceptableEndpoint<FhirEndpointConfiguration<AuditDatasetType extends FhirAuditDataset>,ComponentType extends FhirComponent<AuditDatasetType>>

Returns:

list of default interceptors

createInitialProducerInterceptorChain

public List<Interceptor> createInitialProducerInterceptorChain()

Returns a list of interceptors that are default for FHIR producers. Subclasses can add additional interceptors that are required for a concrete FHIR endpoint.

Specified by:

createInitialProducerInterceptorChain in interface InterceptableEndpoint<FhirEndpointConfiguration<AuditDatasetType extends FhirAuditDataset>,ComponentType extends FhirComponent<AuditDatasetType>>

Returns:

list of default interceptors

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.apache.camel.IsSingleton

getInterceptableConfiguration

public FhirEndpointConfiguration<AuditDatasetType> getInterceptableConfiguration()

Specified by:

getInterceptableConfiguration in interface InterceptableEndpoint<FhirEndpointConfiguration<AuditDatasetType extends FhirAuditDataset>,ComponentType extends FhirComponent<AuditDatasetType>>

Returns:

the configuration for this endpoint

getClientAuditStrategy

public AuditStrategy<AuditDatasetType> getClientAuditStrategy()

Description copied from interface: AuditableEndpoint

Returns client-side audit strategy instance.

Specified by:

getClientAuditStrategy in interface AuditableEndpoint<AuditDatasetType extends FhirAuditDataset>

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 FhirAuditDataset>

Returns:

server-side audit strategy instance

getAuditContext

public AuditContext getAuditContext()

Specified by:

getAuditContext in interface AuditableEndpoint<AuditDatasetType extends FhirAuditDataset>

Returns:

audit context to be used for this endpoint

doCreateConsumer

public org.apache.camel.Consumer doCreateConsumer(org.apache.camel.Processor processor)

Specified by:

doCreateConsumer in interface InterceptableEndpoint<FhirEndpointConfiguration<AuditDatasetType extends FhirAuditDataset>,ComponentType extends FhirComponent<AuditDatasetType>>

Returns:

the actual consumer without any interceptors configured

getClientRequestFactory

public ClientRequestFactory<?> getClientRequestFactory()