Package org.openehealth.ipf.platform.camel.ihe.fhir.iti68bin

Class Iti68BinaryEndpoint

java.lang.Object

org.apache.camel.support.service.BaseService

org.apache.camel.support.service.ServiceSupport

org.apache.camel.support.DefaultEndpoint

org.apache.camel.http.common.HttpCommonEndpoint

org.apache.camel.component.servlet.ServletEndpoint

org.openehealth.ipf.platform.camel.ihe.fhir.iti68bin.Iti68BinaryEndpoint

All Implemented Interfaces:

AutoCloseable, CamelContextAware, DiscoverableService, Endpoint, IsSingleton, Service, ShutdownableService, HasId, HeaderFilterStrategyAware, StatefulService, SuspendableService, AuditableEndpoint<FhirAuditDataset>, InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>

public class Iti68BinaryEndpoint
extends org.apache.camel.component.servlet.ServletEndpoint
implements InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>, AuditableEndpoint<FhirAuditDataset>

Since:

3.7

Author:

Christian Ohr

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

Constructor Summary

Constructors

Constructor	Description
Iti68BinaryEndpoint(String endPointURI, org.apache.camel.component.servlet.ServletComponent component, URI httpUri)

Method Summary

Modifier and Type	Method	Description
Consumer	createConsumer(Processor processor)	Default implementation that creates a consumer by calling InterceptableEndpoint.doCreateConsumer(Processor) and weaves in configured interceptor processors to be executed before calling the first processor in the consumer route.
List<Interceptor>	createInitialConsumerInterceptorChain()
List<Interceptor>	createInitialProducerInterceptorChain()
Consumer	doCreateConsumer(Processor processor)
Producer	doCreateProducer()
AuditContext	getAuditContext()
AuditStrategy<FhirAuditDataset>	getClientAuditStrategy()	Returns client-side audit strategy instance.
Iti68BinaryComponent	getInterceptableComponent()
AuditableEndpointConfiguration	getInterceptableConfiguration()
AuditStrategy<FhirAuditDataset>	getServerAuditStrategy()	Returns server-side audit strategy instance.

Methods inherited from class org.apache.camel.component.servlet.ServletEndpoint

createProducer, getComponent, getContextPath, getFileNameExtWhitelist, getHttpBinding, getServletName, isAttachmentMultipartBinding, isLenientProperties, setAttachmentMultipartBinding, setContextPath, setFileNameExtWhitelist, setHttpBinding, setServletName

Methods inherited from class org.apache.camel.http.common.HttpCommonEndpoint

canConnect, connect, disconnect, getAuthDomain, getAuthHost, getAuthMethod, getAuthMethodPriority, getAuthPassword, getAuthUsername, getBinding, getCookieHandler, getHeaderFilterStrategy, getHttpMethod, getHttpMethodRestrict, getHttpUri, getOkStatusCodeRange, getPath, getPort, getProtocol, getProxyAuthDomain, getProxyAuthHost, getProxyAuthMethod, getProxyAuthNtHost, getProxyAuthPassword, getProxyAuthPort, getProxyAuthScheme, getProxyAuthUsername, getProxyHost, getProxyPort, getResponseBufferSize, getServiceProperties, isAsync, isBridgeEndpoint, isChunked, isConnectionClose, isCopyHeaders, isDisableStreamCache, isEagerCheckContentAvailable, isIgnoreResponseBody, isMapHttpMessageBody, isMapHttpMessageFormUrlEncodedBody, isMapHttpMessageHeaders, isMatchOnUriPrefix, isMuteException, isOptionsEnabled, isPreserveHostHeader, isThrowExceptionOnFailure, isTraceEnabled, isTransferException, setAsync, setAuthDomain, setAuthHost, setAuthMethod, setAuthMethodPriority, setAuthPassword, setAuthUsername, setBridgeEndpoint, setChunked, setConnectionClose, setCookieHandler, setCopyHeaders, setDisableStreamCache, setEagerCheckContentAvailable, setHeaderFilterStrategy, setHttpMethod, setHttpMethodRestrict, setHttpUri, setIgnoreResponseBody, setMapHttpMessageBody, setMapHttpMessageFormUrlEncodedBody, setMapHttpMessageHeaders, setMatchOnUriPrefix, setMuteException, setOkStatusCodeRange, setOptionsEnabled, setPreserveHostHeader, setProxyAuthDomain, setProxyAuthHost, setProxyAuthMethod, setProxyAuthNtHost, setProxyAuthPassword, setProxyAuthPort, setProxyAuthScheme, setProxyAuthUsername, setProxyHost, setProxyPort, setResponseBufferSize, setThrowExceptionOnFailure, setTraceEnabled, setTransferException

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

configureConsumer, configureExchange, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStart, doStop, equals, getCamelContext, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isPollingConsumerBlockWhenFull, isPollingConsumerCopy, isSingleton, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerCopy, setPollingConsumerQueueSize, setProperties, 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 class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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

isAudit

Methods inherited from interface org.apache.camel.Endpoint

configureExchange, configureProperties, createAsyncProducer, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointBaseUri, getEndpointKey, getEndpointUri, getExchangePattern, isLenientProperties, isSingletonProducer, setCamelContext

Methods inherited from interface org.openehealth.ipf.platform.camel.ihe.core.InterceptableEndpoint

createProducer, getCustomInterceptors

Methods inherited from interface org.apache.camel.IsSingleton

isSingleton

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 Details

Iti68BinaryEndpoint

public Iti68BinaryEndpoint(String endPointURI,
 org.apache.camel.component.servlet.ServletComponent component,
 URI httpUri)
                    throws URISyntaxException

Throws:

URISyntaxException

Method Details

createConsumer

public Consumer createConsumer(Processor processor)
                        throws Exception

Description copied from interface: InterceptableEndpoint

Default implementation that creates a consumer by calling InterceptableEndpoint.doCreateConsumer(Processor) and weaves in configured interceptor processors to be executed before calling the first processor in the consumer route.

Specified by:

createConsumer in interface Endpoint

Specified by:

createConsumer in interface InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>

Overrides:

createConsumer in class org.apache.camel.component.servlet.ServletEndpoint

Parameters:

processor - processor for handling the consumed request

Returns:

intercepted consumer

Throws:

Exception

doCreateConsumer

public Consumer doCreateConsumer(Processor processor)
                          throws Exception

Specified by:

doCreateConsumer in interface InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>

Returns:

the actual consumer without any interceptors configured

Throws:

Exception

doCreateProducer

public Producer doCreateProducer()
                          throws Exception

Specified by:

doCreateProducer in interface InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>

Returns:

the actual producer without any interceptors configured

Throws:

Exception

getInterceptableComponent

public Iti68BinaryComponent getInterceptableComponent()

Specified by:

getInterceptableComponent in interface InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>

Returns:

the component for this endpoint

getInterceptableConfiguration

public AuditableEndpointConfiguration getInterceptableConfiguration()

Specified by:

getInterceptableConfiguration in interface InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>

Returns:

the configuration for this endpoint

getClientAuditStrategy

public AuditStrategy<FhirAuditDataset> getClientAuditStrategy()

Description copied from interface: AuditableEndpoint

Returns client-side audit strategy instance.

Specified by:

getClientAuditStrategy in interface AuditableEndpoint<FhirAuditDataset>

Returns:

client-side audit strategy instance

getServerAuditStrategy

public AuditStrategy<FhirAuditDataset> getServerAuditStrategy()

Description copied from interface: AuditableEndpoint

Returns server-side audit strategy instance.

Specified by:

getServerAuditStrategy in interface AuditableEndpoint<FhirAuditDataset>

Returns:

server-side audit strategy instance

getAuditContext

public AuditContext getAuditContext()

Specified by:

getAuditContext in interface AuditableEndpoint<FhirAuditDataset>

Returns:

audit context to be used for this endpoint

createInitialConsumerInterceptorChain

public List<Interceptor> createInitialConsumerInterceptorChain()

Specified by:

createInitialConsumerInterceptorChain in interface InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>

Returns:

the initial chain of consumer interceptors for this endpoint

createInitialProducerInterceptorChain

public List<Interceptor> createInitialProducerInterceptorChain()

Specified by:

createInitialProducerInterceptorChain in interface InterceptableEndpoint<AuditableEndpointConfiguration,Iti68BinaryComponent>

Returns:

the initial chain of producer interceptors for this endpoint