@ManagedResource(description="Managed IPF MLLP ITI Endpoint") public abstract class MllpEndpoint<ConfigType extends MllpEndpointConfiguration,AuditDatasetType extends MllpAuditDataset,ComponentType extends MllpComponent<ConfigType,AuditDatasetType>> extends org.apache.camel.impl.DefaultEndpoint implements InterceptableEndpoint<ConfigType,ComponentType>, HL7v2Endpoint<AuditDatasetType>
Constructor and Description |
---|
MllpEndpoint(ComponentType mllpComponent,
org.apache.camel.component.mina2.Mina2Endpoint wrappedEndpoint,
ConfigType config)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
configureProperties(Map options) |
org.apache.camel.Exchange |
createExchange() |
org.apache.camel.Exchange |
createExchange(org.apache.camel.Exchange exchange) |
org.apache.camel.Exchange |
createExchange(org.apache.camel.ExchangePattern pattern) |
org.apache.camel.PollingConsumer |
createPollingConsumer() |
org.apache.camel.Consumer |
doCreateConsumer(org.apache.camel.Processor processor)
Returns the original starting point of the camel-mina2 route which will be wrapped
into a set of PIX/PDQ-specific interceptors in
Endpoint.createConsumer(Processor) . |
org.apache.camel.Producer |
doCreateProducer()
Returns the original camel-mina2 producer which will be wrapped
into a set of PIX/PDQ-specific interceptors in
Endpoint.createProducer() . |
boolean |
equals(Object object) |
org.apache.camel.CamelContext |
getCamelContext() |
String |
getCharsetName() |
ClientAuthType |
getClientAuthType() |
String |
getClientAuthTypeClass() |
org.apache.camel.Component |
getComponent() |
String |
getComponentType() |
protected ConfigType |
getConfig() |
org.apache.camel.component.mina2.Mina2Configuration |
getConfiguration() |
List<InterceptorFactory> |
getCustomInterceptorFactories() |
String[] |
getCustomInterceptorFactoryList() |
ConsumerDispatchingInterceptor |
getDispatcher() |
String |
getEndpointKey() |
String |
getEndpointUri() |
org.apache.camel.ExchangePattern |
getExchangePattern() |
Hl7v2TransactionConfiguration<AuditDatasetType> |
getHl7v2TransactionConfiguration()
Returns transaction configuration.
|
String |
getHost() |
Hl7v2InteractionId<AuditDatasetType> |
getInteractionId() |
ComponentType |
getInterceptableComponent() |
ConfigType |
getInterceptableConfiguration() |
String[] |
getIoFilters() |
protected ComponentType |
getMllpComponent() |
NakFactory<AuditDatasetType> |
getNakFactory()
Returns transaction-specific ACK and NAK factory.
|
int |
getPort() |
int |
getSegmentFragmentationThreshold()
Returns threshold for segment fragmentation.
|
String[] |
getSslCiphers() |
SSLContext |
getSslContext() |
String[] |
getSslProtocols() |
long |
getTimeout() |
protected org.apache.camel.component.mina2.Mina2Endpoint |
getWrappedEndpoint() |
int |
hashCode() |
boolean |
isLenientProperties() |
boolean |
isSingleton() |
boolean |
isSslSecure() |
boolean |
isSupportSegmentFragmentation()
Returns
true if this endpoint supports segment fragmentation. |
void |
setCamelContext(org.apache.camel.CamelContext camelContext) |
void |
setEndpointUriIfNotSpecified(String value) |
void |
setExchangePattern(org.apache.camel.ExchangePattern exchangePattern) |
String |
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
createConsumer, createInitialConsumerInterceptorChain, createInitialProducerInterceptorChain, createProducer, getCustomInterceptors
public MllpEndpoint(ComponentType mllpComponent, org.apache.camel.component.mina2.Mina2Endpoint wrappedEndpoint, ConfigType config)
mllpComponent
- MLLP Component instance which is creating this endpoint.wrappedEndpoint
- The original camel-mina endpoint instance.config
- Configuration parameters.public ComponentType getInterceptableComponent()
getInterceptableComponent
in interface InterceptableEndpoint<ConfigType extends MllpEndpointConfiguration,ComponentType extends MllpComponent<ConfigType,AuditDatasetType>>
public ConfigType getInterceptableConfiguration()
getInterceptableConfiguration
in interface InterceptableEndpoint<ConfigType extends MllpEndpointConfiguration,ComponentType extends MllpComponent<ConfigType,AuditDatasetType>>
public org.apache.camel.Producer doCreateProducer() throws Exception
Endpoint.createProducer()
.doCreateProducer
in interface InterceptableEndpoint<ConfigType extends MllpEndpointConfiguration,ComponentType extends MllpComponent<ConfigType,AuditDatasetType>>
Exception
public org.apache.camel.Consumer doCreateConsumer(org.apache.camel.Processor processor) throws Exception
Endpoint.createConsumer(Processor)
.doCreateConsumer
in interface InterceptableEndpoint<ConfigType extends MllpEndpointConfiguration,ComponentType extends MllpComponent<ConfigType,AuditDatasetType>>
processor
- The original consumer processor.Exception
public Hl7v2TransactionConfiguration<AuditDatasetType> getHl7v2TransactionConfiguration()
getHl7v2TransactionConfiguration
in interface Hl7v2ConfigurationHolder<AuditDatasetType extends MllpAuditDataset>
public NakFactory<AuditDatasetType> getNakFactory()
getNakFactory
in interface Hl7v2ConfigurationHolder<AuditDatasetType extends MllpAuditDataset>
public Hl7v2InteractionId<AuditDatasetType> getInteractionId()
getInteractionId
in interface Hl7v2ConfigurationHolder<AuditDatasetType extends MllpAuditDataset>
@ManagedAttribute(description="Support Segment Fragmentation Enabled") public boolean isSupportSegmentFragmentation()
true
if this endpoint supports segment fragmentation.@ManagedAttribute(description="Segment Fragmentation Threshold") public int getSegmentFragmentationThreshold()
public SSLContext getSslContext()
@ManagedAttribute(description="Defined SSL Protocols") public String[] getSslProtocols()
@ManagedAttribute(description="Defined SSL Ciphers") public String[] getSslCiphers()
@ManagedAttribute(description="Component Type Name") public String getComponentType()
@ManagedAttribute(description="Mina Host") public String getHost()
@ManagedAttribute(description="Mina Port") public int getPort()
@ManagedAttribute(description="Mina Character Set") public String getCharsetName()
@ManagedAttribute(description="Mina Timeout") public long getTimeout()
@ManagedAttribute(description="Mina Filters") public String[] getIoFilters()
@ManagedAttribute(description="SSL Secure Enabled") public boolean isSslSecure()
public ClientAuthType getClientAuthType()
@ManagedAttribute(description="Client Authentication Type") public String getClientAuthTypeClass()
public List<InterceptorFactory> getCustomInterceptorFactories()
public ConsumerDispatchingInterceptor getDispatcher()
@ManagedAttribute(description="Custom Interceptor Factories") public String[] getCustomInterceptorFactoryList()
public void configureProperties(Map options)
configureProperties
in interface org.apache.camel.Endpoint
configureProperties
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.Exchange createExchange()
createExchange
in interface org.apache.camel.Endpoint
createExchange
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.Exchange createExchange(org.apache.camel.Exchange exchange)
createExchange
in interface org.apache.camel.Endpoint
createExchange
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern pattern)
createExchange
in interface org.apache.camel.Endpoint
createExchange
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.PollingConsumer createPollingConsumer() throws Exception
createPollingConsumer
in interface org.apache.camel.Endpoint
createPollingConsumer
in class org.apache.camel.impl.DefaultEndpoint
Exception
public boolean equals(Object object)
equals
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.CamelContext getCamelContext()
getCamelContext
in interface org.apache.camel.CamelContextAware
getCamelContext
in interface org.apache.camel.Endpoint
getCamelContext
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.Component getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.component.mina2.Mina2Configuration getConfiguration()
public String getEndpointKey()
getEndpointKey
in interface org.apache.camel.Endpoint
getEndpointKey
in class org.apache.camel.impl.DefaultEndpoint
public String getEndpointUri()
getEndpointUri
in interface org.apache.camel.Endpoint
getEndpointUri
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.ExchangePattern getExchangePattern()
getExchangePattern
in class org.apache.camel.impl.DefaultEndpoint
public int hashCode()
hashCode
in class org.apache.camel.impl.DefaultEndpoint
public boolean isLenientProperties()
isLenientProperties
in interface org.apache.camel.Endpoint
isLenientProperties
in class org.apache.camel.impl.DefaultEndpoint
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public void setCamelContext(org.apache.camel.CamelContext camelContext)
setCamelContext
in interface org.apache.camel.CamelContextAware
setCamelContext
in interface org.apache.camel.Endpoint
setCamelContext
in class org.apache.camel.impl.DefaultEndpoint
public void setEndpointUriIfNotSpecified(String value)
setEndpointUriIfNotSpecified
in class org.apache.camel.impl.DefaultEndpoint
public void setExchangePattern(org.apache.camel.ExchangePattern exchangePattern)
setExchangePattern
in class org.apache.camel.impl.DefaultEndpoint
public String toString()
toString
in class org.apache.camel.impl.DefaultEndpoint
@Generated(value="lombok") protected ConfigType getConfig()
@Generated(value="lombok") protected ComponentType getMllpComponent()
@Generated(value="lombok") protected org.apache.camel.component.mina2.Mina2Endpoint getWrappedEndpoint()
Copyright © 2018 Open eHealth Foundation. All rights reserved.