public class MllpTransactionEndpoint<AuditDatasetType extends MllpAuditDataset> extends MllpEndpoint<MllpTransactionEndpointConfiguration,AuditDatasetType,MllpTransactionComponent<AuditDatasetType>> implements AuditableEndpoint<AuditDatasetType>
Constructor and Description |
---|
MllpTransactionEndpoint(MllpTransactionComponent<AuditDatasetType> mllpComponent,
org.apache.camel.component.mina2.Mina2Endpoint wrappedEndpoint,
MllpTransactionEndpointConfiguration config)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
List<Interceptor> |
createInitialConsumerInterceptorChain() |
List<Interceptor> |
createInitialProducerInterceptorChain() |
AuditContext |
getAuditContext() |
AuditStrategy<AuditDatasetType> |
getClientAuditStrategy()
Returns client-side audit strategy instance.
|
int |
getInteractiveContinuationDefaultThreshold()
Returns default threshold for interactive continuation
(relevant on consumer side only).
|
InteractiveContinuationStorage |
getInteractiveContinuationStorage()
Returns the interactive continuation storage bean.
|
String |
getInteractiveContinuationStorageType() |
AuditStrategy<AuditDatasetType> |
getServerAuditStrategy()
Returns server-side audit strategy instance.
|
UnsolicitedFragmentationStorage |
getUnsolicitedFragmentationStorage()
Returns the unsolicited fragmentation storage bean.
|
String |
getUnsolicitedFragmentationStorageType() |
int |
getUnsolicitedFragmentationThreshold()
Returns threshold for unsolicited message fragmentation
(relevant on producer side only).
|
boolean |
isAudit()
Returns true when ATNA auditing should be performed.
|
boolean |
isAutoCancel()
Returns true, when the producer should automatically send a cancel
message after it has collected all interactive continuation pieces.
|
boolean |
isSupportInteractiveContinuation()
Returns
true if this endpoint supports interactive continuation. |
boolean |
isSupportUnsolicitedFragmentation()
Returns
true if this endpoint supports unsolicited message fragmentation. |
configureProperties, createExchange, createExchange, createExchange, createPollingConsumer, doCreateConsumer, doCreateProducer, equals, getCamelContext, getCharsetName, getClientAuthType, getClientAuthTypeClass, getComponent, getComponentType, getConfig, getConfiguration, getCustomInterceptorFactories, getCustomInterceptorFactoryList, getDispatcher, getEndpointKey, getEndpointUri, getExchangePattern, getHl7v2TransactionConfiguration, getHost, getInteractionId, getInterceptableComponent, getInterceptableConfiguration, getIoFilters, getMllpComponent, getNakFactory, getPort, getSegmentFragmentationThreshold, getSslCiphers, getSslContext, getSslProtocols, getTimeout, getWrappedEndpoint, hashCode, isLenientProperties, isSingleton, isSslSecure, isSupportSegmentFragmentation, setCamelContext, setEndpointUriIfNotSpecified, setExchangePattern, toString
configureConsumer, configurePollingConsumer, createEndpointConfiguration, createEndpointUri, doStart, doStop, getConsumerProperties, getEndpointConfiguration, getExceptionHandler, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, isBridgeErrorHandler, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setExceptionHandler, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
configureProperties, createConsumer, createExchange, createExchange, createExchange, createPollingConsumer, createProducer, getCamelContext, getEndpointConfiguration, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContext
createConsumer, createProducer, getCustomInterceptors
public MllpTransactionEndpoint(MllpTransactionComponent<AuditDatasetType> mllpComponent, org.apache.camel.component.mina2.Mina2Endpoint wrappedEndpoint, MllpTransactionEndpointConfiguration config)
mllpComponent
- MLLP Component instance which is creating this endpoint.wrappedEndpoint
- The original camel-mina endpoint instance.config
- Configuration parameters.public List<Interceptor> createInitialConsumerInterceptorChain()
createInitialConsumerInterceptorChain
in interface InterceptableEndpoint<MllpTransactionEndpointConfiguration,MllpTransactionComponent<AuditDatasetType extends MllpAuditDataset>>
public List<Interceptor> createInitialProducerInterceptorChain()
createInitialProducerInterceptorChain
in interface InterceptableEndpoint<MllpTransactionEndpointConfiguration,MllpTransactionComponent<AuditDatasetType extends MllpAuditDataset>>
public AuditContext getAuditContext()
getAuditContext
in interface AuditableEndpoint<AuditDatasetType extends MllpAuditDataset>
@ManagedAttribute(description="Audit Enabled") public boolean isAudit()
isAudit
in interface AuditableEndpoint<AuditDatasetType extends MllpAuditDataset>
public AuditStrategy<AuditDatasetType> getClientAuditStrategy()
AuditableEndpoint
getClientAuditStrategy
in interface AuditableEndpoint<AuditDatasetType extends MllpAuditDataset>
public AuditStrategy<AuditDatasetType> getServerAuditStrategy()
AuditableEndpoint
getServerAuditStrategy
in interface AuditableEndpoint<AuditDatasetType extends MllpAuditDataset>
@ManagedAttribute(description="Support Unsolicited Fragmentation Enabled") public boolean isSupportUnsolicitedFragmentation()
true
if this endpoint supports unsolicited message fragmentation.@ManagedAttribute(description="Unsolicited Fragmentation Threshold") public int getUnsolicitedFragmentationThreshold()
public UnsolicitedFragmentationStorage getUnsolicitedFragmentationStorage()
@ManagedAttribute(description="Unsolicited Fragmentation Storage Cache Type") public String getUnsolicitedFragmentationStorageType()
@ManagedAttribute(description="Support Interactive Continuation Enabled") public boolean isSupportInteractiveContinuation()
true
if this endpoint supports interactive continuation.@ManagedAttribute(description="Interactive Continuation Default Threshold") public int getInteractiveContinuationDefaultThreshold()
This value will be used when interactive continuation is generally supported by this endpoint and is particularly applicable for the current response message, and the corresponding request message does not set the records count threshold explicitly (RCP-2-1==integer, RCP-2-2=='RD').
public InteractiveContinuationStorage getInteractiveContinuationStorage()
@ManagedAttribute(description="Auto Cancel Enabled") public boolean isAutoCancel()
@ManagedAttribute(description="Interactive Continuation Storage Cache Type") public String getInteractiveContinuationStorageType()
Copyright © 2018 Open eHealth Foundation. All rights reserved.