Class Hl7v3ContinuationAwareEndpoint
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultEndpoint
-
- org.openehealth.ipf.platform.camel.ihe.ws.AbstractWsEndpoint<Hl7v3AuditDataset,ConfigType>
-
- org.openehealth.ipf.platform.camel.ihe.hl7v3.Hl7v3Endpoint<Hl7v3ContinuationAwareWsTransactionConfiguration>
-
- org.openehealth.ipf.platform.camel.ihe.hl7v3.Hl7v3ContinuationAwareEndpoint
-
- All Implemented Interfaces:
AutoCloseable
,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<Hl7v3AuditDataset>
public class Hl7v3ContinuationAwareEndpoint extends Hl7v3Endpoint<Hl7v3ContinuationAwareWsTransactionConfiguration>
Camel endpoint implementation for HL7v3-based IHE components with interactive response continuation support.- Author:
- Dmytro Rud
-
-
Field Summary
-
Fields inherited from class org.openehealth.ipf.platform.camel.ihe.ws.AbstractWsEndpoint
CORRELATION_KEY_HEADER_NAME, INCOMING_HTTP_HEADERS, INCOMING_SOAP_HEADERS, OUTGOING_HTTP_HEADERS, OUTGOING_SOAP_HEADERS, WSA_REPLYTO_HEADER_NAME
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
Hl7v3ContinuationAwareEndpoint(String endpointUri, String address, AbstractWsComponent<Hl7v3AuditDataset,Hl7v3ContinuationAwareWsTransactionConfiguration,? extends WsInteractionId<Hl7v3ContinuationAwareWsTransactionConfiguration>> component, Map<String,Object> parameters)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Hl7v3ContinuationStorage
getContinuationStorage()
Returns storage bean for continuation fragments.int
getDefaultContinuationThreshold()
Returns default count of data records to be sent in the first response fragment, when the request does not contain "initialQuantity" element.JaxWsClientFactory<Hl7v3AuditDataset>
getJaxWsClientFactory()
JaxWsServiceFactory<Hl7v3AuditDataset>
getJaxWsServiceFactory()
AbstractWsProducer<Hl7v3AuditDataset,Hl7v3ContinuationAwareWsTransactionConfiguration,?,?>
getProducer(AbstractWsEndpoint<Hl7v3AuditDataset,Hl7v3ContinuationAwareWsTransactionConfiguration> endpoint, JaxWsClientFactory<Hl7v3AuditDataset> clientFactory)
Constructs and returns a transaction-specific Camel producer instanceboolean
isAutoCancel()
Returnstrue
when a "cancel continuation" message should be automatically sent to the server after all continuation fragments have been read.boolean
isManualAudit()
boolean
isSupportContinuation()
Returnstrue
when this endpoint supports HL7v3 continuation.boolean
isValidationOnContinuation()
void
setAutoCancel(boolean autoCancel)
void
setContinuationStorage(Hl7v3ContinuationStorage continuationStorage)
void
setDefaultContinuationThreshold(int defaultContinuationThreshold)
void
setSupportContinuation(boolean supportContinuation)
void
setValidationOnContinuation(boolean validationOnContinuation)
-
Methods inherited from class org.openehealth.ipf.platform.camel.ihe.ws.AbstractWsEndpoint
createConsumer, createProducer, getAuditContext, getClientAuditStrategy, getComponent, getCorrelator, getCustomInterceptors, getCustomServiceInstance, getFeatures, getHomeCommunityId, getHostnameVerifier, getPassword, getProperties, getRejectionHandlingStrategy, getSchemaLocations, getSecurityInformation, getServerAuditStrategy, getServiceAddress, getServiceInstance, getServiceUrl, getSslContextParameters, getUsername, isAddressing, isAudit, isMtom, isSecure, isSingleton, isSwaOutSupport, setAuditContext, setCorrelator, setHomeCommunityId, setHomeCommunityId, setHostnameVerifier, setPassword, setRejectionHandlingStrategy, setSecure, setSslContextParameters, setUsername
-
Methods inherited from class org.apache.camel.support.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStart, doStop, equals, getCamelContext, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, 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.apache.camel.Endpoint
configureProperties, createAsyncProducer, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointBaseUri, getEndpointKey, getEndpointUri, isLenientProperties, isSingletonProducer, setCamelContext
-
-
-
-
Constructor Detail
-
Hl7v3ContinuationAwareEndpoint
protected Hl7v3ContinuationAwareEndpoint(String endpointUri, String address, AbstractWsComponent<Hl7v3AuditDataset,Hl7v3ContinuationAwareWsTransactionConfiguration,? extends WsInteractionId<Hl7v3ContinuationAwareWsTransactionConfiguration>> component, Map<String,Object> parameters)
-
-
Method Detail
-
getProducer
public AbstractWsProducer<Hl7v3AuditDataset,Hl7v3ContinuationAwareWsTransactionConfiguration,?,?> getProducer(AbstractWsEndpoint<Hl7v3AuditDataset,Hl7v3ContinuationAwareWsTransactionConfiguration> endpoint, JaxWsClientFactory<Hl7v3AuditDataset> clientFactory)
Description copied from class:AbstractWsEndpoint
Constructs and returns a transaction-specific Camel producer instance- Specified by:
getProducer
in classAbstractWsEndpoint<Hl7v3AuditDataset,Hl7v3ContinuationAwareWsTransactionConfiguration>
clientFactory
- JAX-WS client factory instance.- Returns:
- Camel producer instance.
-
isSupportContinuation
public boolean isSupportContinuation()
Returnstrue
when this endpoint supports HL7v3 continuation.
-
setSupportContinuation
public void setSupportContinuation(boolean supportContinuation)
-
getDefaultContinuationThreshold
public int getDefaultContinuationThreshold()
Returns default count of data records to be sent in the first response fragment, when the request does not contain "initialQuantity" element. Negative values mean "no continuation, when initialQuantity is not specified". This parameter is relevant only on consumer side.
-
setDefaultContinuationThreshold
public void setDefaultContinuationThreshold(int defaultContinuationThreshold)
-
getContinuationStorage
public Hl7v3ContinuationStorage getContinuationStorage()
Returns storage bean for continuation fragments. This parameter is relevant only on consumer side.
-
setContinuationStorage
public void setContinuationStorage(Hl7v3ContinuationStorage continuationStorage)
-
isAutoCancel
public boolean isAutoCancel()
Returnstrue
when a "cancel continuation" message should be automatically sent to the server after all continuation fragments have been read. This parameter is relevant only on producer side.
-
setAutoCancel
public void setAutoCancel(boolean autoCancel)
-
isValidationOnContinuation
public boolean isValidationOnContinuation()
- Returns:
true
when messages, which are internally handled when performing HL7v3 interactive continuation, should be validated.
-
setValidationOnContinuation
public void setValidationOnContinuation(boolean validationOnContinuation)
-
isManualAudit
public boolean isManualAudit()
- Returns:
true
if ATNA audit strategies must be manually applied in Camel producer and consumer instead of CXF interceptors. This will be the case when interactive response continuation is supported.
-
getJaxWsClientFactory
public JaxWsClientFactory<Hl7v3AuditDataset> getJaxWsClientFactory()
- Overrides:
getJaxWsClientFactory
in classHl7v3Endpoint<Hl7v3ContinuationAwareWsTransactionConfiguration>
- Returns:
- JAX-WS client object factory.
-
getJaxWsServiceFactory
public JaxWsServiceFactory<Hl7v3AuditDataset> getJaxWsServiceFactory()
- Overrides:
getJaxWsServiceFactory
in classHl7v3Endpoint<Hl7v3ContinuationAwareWsTransactionConfiguration>
- Returns:
- JAX-WS service object factory.
-
-