You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by qu...@apache.org on 2018/01/12 18:22:50 UTC
[camel] branch master updated: CAMEL-12106 - fix missed checkstyle
issues
This is an automated email from the ASF dual-hosted git repository.
quinn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new fb9c4a2 CAMEL-12106 - fix missed checkstyle issues
fb9c4a2 is described below
commit fb9c4a252d4ea6bec39aa1c00aa6e3e207357f34
Author: Quinn Stevenson <qu...@apache.org>
AuthorDate: Fri Jan 12 11:22:44 2018 -0700
CAMEL-12106 - fix missed checkstyle issues
---
.../camel-mllp/src/main/docs/mllp-component.adoc | 41 ++-
.../apache/camel/component/mllp/MllpComponent.java | 15 +
.../apache/camel/component/mllp/MllpEndpoint.java | 32 +-
.../component/mllp/MllpTcpClientProducer.java | 3 +-
.../component/mllp/MllpTcpServerConsumer.java | 3 +-
.../springboot/MllpComponentConfiguration.java | 407 ++++++++++++++++++++-
6 files changed, 468 insertions(+), 33 deletions(-)
diff --git a/components/camel-mllp/src/main/docs/mllp-component.adoc b/components/camel-mllp/src/main/docs/mllp-component.adoc
index 6bccff6..834eed8 100644
--- a/components/camel-mllp/src/main/docs/mllp-component.adoc
+++ b/components/camel-mllp/src/main/docs/mllp-component.adoc
@@ -1,6 +1,6 @@
== MLLP Component
-*Available as of Camel version 2.17*
+*Available as of Camel version *
The MLLP component is specifically designed to handle the nuances of the
MLLP protocol and provide the functionality required by Healthcare
@@ -40,7 +40,18 @@ for this component:
// component options: START
-The MLLP component has no options.
+The MLLP component supports 4 options which are listed below.
+
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *logPhi* (common) | Set the component to log PHI data. | | Boolean
+| *logPhiMaxBytes* (common) | Set the maximum number of bytes of PHI that will be logged in a log entry. | | Integer
+| *configuration* (common) | Sets the default configuration to use when creating MLLP endpoints. | | MllpConfiguration
+| *resolveProperty Placeholders* (advanced) | Whether the component should resolve property placeholders on itself when starting. Only properties which are of String type can use property placeholders. | true | boolean
+|===
// component options: END
@@ -68,33 +79,37 @@ with the following path and query parameters:
| *port* | *Required* Port number for the TCP connection | | int
|===
-==== Query Parameters (22 parameters):
+==== Query Parameters (26 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
| *autoAck* (common) | Enable/Disable the automatic generation of a MLLP Acknowledgement MLLP Consumers only | true | boolean
-| *bufferWrites* (common) | Enable/Disable the validation of HL7 Payloads If enabled MLLP Payloads are buffered and written to the external system in a single write(byte) operation. If disabled the MLLP payload will not be buffered and three write operations will be used. The first operation will write the MLLP start-of-block character 0x0b (ASCII VT) the second operation will write the HL7 payload and the third operation will writh the MLLP end-of-block character and the MLLP end-of-dat [...]
+| *bufferWrites* (common) | *Deprecated* Enable/Disable the validation of HL7 Payloads | false | boolean
| *hl7Headers* (common) | Enable/Disable the automatic generation of message headers from the HL7 Message MLLP Consumers only | true | boolean
-| *keepAlive* (common) | Enable/disable the SO_KEEPALIVE socket option. | true | boolean
-| *reuseAddress* (common) | Enable/disable the SO_REUSEADDR socket option. | false | boolean
-| *tcpNoDelay* (common) | Enable/disable the TCP_NODELAY socket option. | true | boolean
+| *requireEndOfData* (common) | Enable disable strict compliance to the MLLP standard. The MLLP standard specifies START_OF_BLOCKhl7 payloadEND_OF_BLOCKEND_OF_DATA however some systems do not send the final END_OF_DATA byte. This setting controls whether or not the final END_OF_DATA byte is required or optional. | true | boolean
+| *stringPayload* (common) | Enable/Disable converting the payload to a String. If enabled HL7 Payloads received from external systems will be validated converted to a String. If the charsetName property is set that character set will be used for the conversion. If the charsetName property is not set the value of MSH-18 will be used to determine th appropriate character set. If MSH-18 is not set then the default ASCII character set will be use. | true | boolean
| *validatePayload* (common) | Enable/Disable the validation of HL7 Payloads If enabled HL7 Payloads received from external systems will be validated (see Hl7Util.generateInvalidPayloadExceptionMessage for details on the validation). If and invalid payload is detected a MllpInvalidMessageException (for consumers) or a MllpInvalidAcknowledgementException will be thrown. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler which mean any exceptions occurred while the consumer is trying to pickup incoming messages or the likes will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions that will be logged at WARN or ERROR level and ignored. | false | boolean
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this options is not in use. By default the consumer will deal with exceptions that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
-| *backlog* (advanced) | The maximum queue length for incoming connection indications (a request to connect) is set to the backlog parameter. If a connection indication arrives when the queue is full the connection is refused. | 5 | int
-| *receiveBufferSize* (advanced) | Sets the SO_RCVBUF option to the specified value (in bytes) | | Integer
-| *sendBufferSize* (advanced) | Sets the SO_SNDBUF option to the specified value (in bytes) | | Integer
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *charsetName* (codec) | Set the CamelCharsetName property on the exchange | | String
+| *backlog* (tcp) | The maximum queue length for incoming connection indications (a request to connect) is set to the backlog parameter. If a connection indication arrives when the queue is full the connection is refused. | 5 | Integer
+| *maxConcurrentConsumers* (tcp) | The maximum number of concurrent MLLP Consumer connections that will be allowed. If a new connection is received and the maximum is number are already established the new connection will be reset immediately. | 5 | int
+| *reuseAddress* (tcp) | Enable/disable the SO_REUSEADDR socket option. | true | Boolean
| *acceptTimeout* (timeout) | Timeout (in milliseconds) while waiting for a TCP connection TCP Server Only | 60000 | int
| *bindRetryInterval* (timeout) | TCP Server Only - The number of milliseconds to wait between bind attempts | 5000 | int
| *bindTimeout* (timeout) | TCP Server Only - The number of milliseconds to retry binding to a server port | 30000 | int
+| *keepAlive* (tcp) | Enable/disable the SO_KEEPALIVE socket option. | true | Boolean
| *connectTimeout* (timeout) | Timeout (in milliseconds) for establishing for a TCP connection TCP Client only | 30000 | int
-| *maxReceiveTimeouts* (timeout) | The maximum number of timeouts (specified by receiveTimeout) allowed before the TCP Connection will be reset. | -1 | int
+| *receiveBufferSize* (tcp) | Sets the SO_RCVBUF option to the specified value (in bytes) | 8192 | Integer
+| *sendBufferSize* (tcp) | Sets the SO_SNDBUF option to the specified value (in bytes) | 8192 | Integer
+| *idleTimeout* (timeout) | The approximate idle time allowed before the Client TCP Connection will be reset. A null value or a value less than or equal to zero will disable the idle timeout. | | Integer
+| *maxReceiveTimeouts* (timeout) | *Deprecated* The maximum number of timeouts (specified by receiveTimeout) allowed before the TCP Connection will be reset. | | Integer
+| *tcpNoDelay* (tcp) | Enable/disable the TCP_NODELAY socket option. | true | Boolean
| *readTimeout* (timeout) | The SO_TIMEOUT value (in milliseconds) used after the start of an MLLP frame has been received | 500 | int
-| *receiveTimeout* (timeout) | The SO_TIMEOUT value (in milliseconds) used when waiting for the start of an MLLP frame | 10000 | int
+| *receiveTimeout* (timeout) | The SO_TIMEOUT value (in milliseconds) used when waiting for the start of an MLLP frame | 15000 | int
+| *charsetName* (codec) | Set the CamelCharsetName property on the exchange | | String
|===
// endpoint options: END
diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpComponent.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpComponent.java
index 4525e08..8a43682 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpComponent.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpComponent.java
@@ -88,6 +88,11 @@ public class MllpComponent extends UriEndpointComponent {
return answer;
}
+ /**
+ * Set the component to log PHI data.
+ *
+ * @param logPhi true enables PHI logging; false disables it.
+ */
public static void setLogPhi(Boolean logPhi) {
MllpComponent.logPhi = logPhi;
}
@@ -116,6 +121,11 @@ public class MllpComponent extends UriEndpointComponent {
return answer;
}
+ /**
+ * Set the maximum number of bytes of PHI that will be logged in a log entry.
+ *
+ * @param logPhiMaxBytes the maximum number of bytes to log.
+ */
public static void setLogPhiMaxBytes(Integer logPhiMaxBytes) {
MllpComponent.logPhiMaxBytes = logPhiMaxBytes;
}
@@ -130,6 +140,11 @@ public class MllpComponent extends UriEndpointComponent {
return configuration;
}
+ /**
+ * Sets the default configuration to use when creating MLLP endpoints.
+ *
+ * @param configuration the default configuration.
+ */
public void setConfiguration(MllpConfiguration configuration) {
this.configuration = configuration;
}
diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpEndpoint.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpEndpoint.java
index ec7a347..33820b5 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpEndpoint.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpEndpoint.java
@@ -52,22 +52,22 @@ import org.slf4j.LoggerFactory;
@ManagedResource(description = "MLLP Endpoint")
@UriEndpoint(scheme = "mllp", title = "MLLP", syntax = "mllp:hostname:port", consumerClass = MllpTcpServerConsumer.class, label = "mllp")
public class MllpEndpoint extends DefaultEndpoint {
- // Use constants from MllpProtocolConstants
- @Deprecated()
- public static final char START_OF_BLOCK = MllpProtocolConstants.START_OF_BLOCK;
- @Deprecated()
- public static final char END_OF_BLOCK = MllpProtocolConstants.END_OF_BLOCK;
- @Deprecated()
- public static final char END_OF_DATA = MllpProtocolConstants.END_OF_DATA;
- @Deprecated()
- public static final int END_OF_STREAM = MllpProtocolConstants.END_OF_STREAM;
- @Deprecated()
- public static final char SEGMENT_DELIMITER = MllpProtocolConstants.SEGMENT_DELIMITER;
- @Deprecated()
- public static final char MESSAGE_TERMINATOR = MllpProtocolConstants.MESSAGE_TERMINATOR;
-
- @Deprecated // Use constants from MllpProtocolConstants
- public static final Charset DEFAULT_CHARSET = MllpProtocolConstants.DEFAULT_CHARSET;
+ // Use constants from MllpProtocolConstants
+ @Deprecated()
+ public static final char START_OF_BLOCK = MllpProtocolConstants.START_OF_BLOCK;
+ @Deprecated()
+ public static final char END_OF_BLOCK = MllpProtocolConstants.END_OF_BLOCK;
+ @Deprecated()
+ public static final char END_OF_DATA = MllpProtocolConstants.END_OF_DATA;
+ @Deprecated()
+ public static final int END_OF_STREAM = MllpProtocolConstants.END_OF_STREAM;
+ @Deprecated()
+ public static final char SEGMENT_DELIMITER = MllpProtocolConstants.SEGMENT_DELIMITER;
+ @Deprecated()
+ public static final char MESSAGE_TERMINATOR = MllpProtocolConstants.MESSAGE_TERMINATOR;
+
+ @Deprecated // Use constants from MllpProtocolConstants
+ public static final Charset DEFAULT_CHARSET = MllpProtocolConstants.DEFAULT_CHARSET;
private static final Logger LOG = LoggerFactory.getLogger(MllpEndpoint.class);
diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
index 6c05ae4..e91ccb6 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
@@ -246,7 +246,8 @@ public class MllpTcpClientProducer extends DefaultProducer implements Runnable {
log.debug("Populating message headers with the acknowledgement from the external system");
message.setHeader(MllpConstants.MLLP_ACKNOWLEDGEMENT, acknowledgementBytes);
if (acknowledgementBytes != null && acknowledgementBytes.length > 0) {
- message.setHeader(MllpConstants.MLLP_ACKNOWLEDGEMENT_STRING, getEndpoint().createNewString(acknowledgementBytes, message.getHeader(MllpConstants.MLLP_CHARSET, String.class)));
+ message.setHeader(MllpConstants.MLLP_ACKNOWLEDGEMENT_STRING,
+ getEndpoint().createNewString(acknowledgementBytes, message.getHeader(MllpConstants.MLLP_CHARSET, String.class)));
} else {
message.setHeader(MllpConstants.MLLP_ACKNOWLEDGEMENT_STRING, "");
}
diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpServerConsumer.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpServerConsumer.java
index ac2d95d..bc4f41d 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpServerConsumer.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpServerConsumer.java
@@ -145,7 +145,8 @@ public class MllpTcpServerConsumer extends DefaultConsumer {
// Log usage of deprecated URI options
if (getConfiguration().hasMaxReceiveTimeouts()) {
if (getConfiguration().hasIdleTimeout()) {
- log.info("Both maxReceivedTimeouts {} and idleTimeout {} URI options are specified - idleTimeout will be used", getConfiguration().getMaxReceiveTimeouts(), getConfiguration().getIdleTimeout());
+ log.info("Both maxReceivedTimeouts {} and idleTimeout {} URI options are specified - idleTimeout will be used",
+ getConfiguration().getMaxReceiveTimeouts(), getConfiguration().getIdleTimeout());
} else {
getConfiguration().setIdleTimeout(getConfiguration().getMaxReceiveTimeouts() * getConfiguration().getReceiveTimeout());
log.info("Deprecated URI option maxReceivedTimeouts {} specified - idleTimeout {} will be used", getConfiguration().getMaxReceiveTimeouts(), getConfiguration().getIdleTimeout());
diff --git a/platforms/spring-boot/components-starter/camel-mllp-starter/src/main/java/org/apache/camel/component/mllp/springboot/MllpComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-mllp-starter/src/main/java/org/apache/camel/component/mllp/springboot/MllpComponentConfiguration.java
index 9f588ce..536efe9 100644
--- a/platforms/spring-boot/components-starter/camel-mllp-starter/src/main/java/org/apache/camel/component/mllp/springboot/MllpComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-mllp-starter/src/main/java/org/apache/camel/component/mllp/springboot/MllpComponentConfiguration.java
@@ -19,10 +19,12 @@ package org.apache.camel.component.mllp.springboot;
import javax.annotation.Generated;
import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.DeprecatedConfigurationProperty;
/**
- * Provides functionality required by Healthcare providers to communicate with
- * other systems using the MLLP protocol.
+ * The MLLP component is designed to handle the MLLP protocol and provide the
+ * functionality required by Healthcare providers to communicate with other
+ * systems using the MLLP protocol.
*
* Generated by camel-package-maven-plugin - do not edit this file!
*/
@@ -33,12 +35,50 @@ public class MllpComponentConfiguration
ComponentConfigurationPropertiesCommon {
/**
+ * Set the component to log PHI data.
+ */
+ private Boolean logPhi;
+ /**
+ * Set the maximum number of bytes of PHI that will be logged in a log
+ * entry.
+ */
+ private Integer logPhiMaxBytes;
+ /**
+ * Sets the default configuration to use when creating MLLP endpoints.
+ */
+ private MllpConfigurationNestedConfiguration configuration;
+ /**
* Whether the component should resolve property placeholders on itself when
* starting. Only properties which are of String type can use property
* placeholders.
*/
private Boolean resolvePropertyPlaceholders = true;
+ public Boolean getLogPhi() {
+ return logPhi;
+ }
+
+ public void setLogPhi(Boolean logPhi) {
+ this.logPhi = logPhi;
+ }
+
+ public Integer getLogPhiMaxBytes() {
+ return logPhiMaxBytes;
+ }
+
+ public void setLogPhiMaxBytes(Integer logPhiMaxBytes) {
+ this.logPhiMaxBytes = logPhiMaxBytes;
+ }
+
+ public MllpConfigurationNestedConfiguration getConfiguration() {
+ return configuration;
+ }
+
+ public void setConfiguration(
+ MllpConfigurationNestedConfiguration configuration) {
+ this.configuration = configuration;
+ }
+
public Boolean getResolvePropertyPlaceholders() {
return resolvePropertyPlaceholders;
}
@@ -47,4 +87,367 @@ public class MllpComponentConfiguration
Boolean resolvePropertyPlaceholders) {
this.resolvePropertyPlaceholders = resolvePropertyPlaceholders;
}
+
+ public static class MllpConfigurationNestedConfiguration {
+ public static final Class CAMEL_NESTED_CLASS = org.apache.camel.component.mllp.MllpConfiguration.class;
+ /**
+ * Set the CamelCharsetName property on the exchange
+ *
+ * @param charsetName
+ * the charset
+ */
+ private String charsetName;
+ /**
+ * The maximum queue length for incoming connection indications (a
+ * request to connect) is set to the backlog parameter. If a connection
+ * indication arrives when the queue is full, the connection is refused.
+ */
+ private Integer backlog = 5;
+ /**
+ * TCP Server Only - The number of milliseconds to retry binding to a
+ * server port
+ */
+ private Integer bindTimeout = 30000;
+ /**
+ * TCP Server Only - The number of milliseconds to wait between bind
+ * attempts
+ */
+ private Integer bindRetryInterval = 5000;
+ /**
+ * Timeout (in milliseconds) while waiting for a TCP connection
+ * <p/>
+ * TCP Server Only
+ *
+ * @param acceptTimeout
+ * timeout in milliseconds
+ */
+ private Integer acceptTimeout = 60000;
+ /**
+ * Timeout (in milliseconds) for establishing for a TCP connection
+ * <p/>
+ * TCP Client only
+ *
+ * @param connectTimeout
+ * timeout in milliseconds
+ */
+ private Integer connectTimeout = 30000;
+ /**
+ * The SO_TIMEOUT value (in milliseconds) used when waiting for the
+ * start of an MLLP frame
+ *
+ * @param receiveTimeout
+ * timeout in milliseconds
+ */
+ private Integer receiveTimeout = 15000;
+ /**
+ * The maximum number of concurrent MLLP Consumer connections that will
+ * be allowed. If a new connection is received and the maximum is number
+ * are already established, the new connection will be reset
+ * immediately.
+ *
+ * @param maxConcurrentConsumers
+ * the maximum number of concurrent consumer connections
+ * allowed
+ */
+ private Integer maxConcurrentConsumers = 5;
+ /**
+ * The maximum number of timeouts (specified by receiveTimeout) allowed
+ * before the TCP Connection will be reset.
+ *
+ * @param maxReceiveTimeouts
+ * maximum number of receiveTimeouts
+ * @deprecated Use the idleTimeout URI parameter. For backward
+ * compibility, setting this parameter will result in an
+ * idle timeout of maxReceiveTimeouts * receiveTimeout. If
+ * idleTimeout is also specified, this parameter will be
+ * ignored.
+ */
+ @Deprecated
+ private Integer maxReceiveTimeouts;
+ /**
+ * The approximate idle time allowed before the Client TCP Connection
+ * will be reset. A null value or a value less than or equal to zero
+ * will disable the idle timeout.
+ *
+ * @param idleTimeout
+ * timeout in milliseconds
+ */
+ private Integer idleTimeout;
+ /**
+ * The SO_TIMEOUT value (in milliseconds) used after the start of an
+ * MLLP frame has been received
+ *
+ * @param readTimeout
+ * timeout in milliseconds
+ */
+ private Integer readTimeout = 500;
+ /**
+ * Enable/disable the SO_KEEPALIVE socket option.
+ *
+ * @param keepAlive
+ * enable SO_KEEPALIVE when true; disable SO_KEEPALIVE when
+ * false; use system default when null
+ */
+ private Boolean keepAlive = true;
+ /**
+ * Enable/disable the TCP_NODELAY socket option.
+ *
+ * @param tcpNoDelay
+ * enable TCP_NODELAY when true; disable TCP_NODELAY when
+ * false; use system default when null
+ */
+ private Boolean tcpNoDelay = true;
+ /**
+ * Sets the SO_RCVBUF option to the specified value (in bytes)
+ *
+ * @param receiveBufferSize
+ * the SO_RCVBUF option value. If null, the system default is
+ * used
+ */
+ private Integer receiveBufferSize = 8192;
+ /**
+ * Sets the SO_SNDBUF option to the specified value (in bytes)
+ *
+ * @param sendBufferSize
+ * the SO_SNDBUF option value. If null, the system default is
+ * used
+ */
+ private Integer sendBufferSize = 8192;
+ /**
+ * Enable/Disable the automatic generation of a MLLP Acknowledgement
+ * MLLP Consumers only
+ *
+ * @param autoAck
+ * enabled if true, otherwise disabled
+ */
+ private Boolean autoAck = true;
+ /**
+ * Enable/Disable the automatic generation of message headers from the
+ * HL7 Message MLLP Consumers only
+ *
+ * @param hl7Headers
+ * enabled if true, otherwise disabled
+ */
+ private Boolean hl7Headers = true;
+ /**
+ * Enable disable strict compliance to the MLLP standard. The MLLP
+ * standard specifies [START_OF_BLOCK]hl7
+ * payload[END_OF_BLOCK][END_OF_DATA], however, some systems do not send
+ * the final END_OF_DATA byte. This setting controls whether or not the
+ * final END_OF_DATA byte is required or optional.
+ *
+ * @param requireEndOfData
+ * the trailing END_OF_DATA byte is required if true;
+ * optional otherwise
+ */
+ private Boolean requireEndOfData = true;
+ /**
+ * Enable/Disable converting the payload to a String. If enabled, HL7
+ * Payloads received from external systems will be validated converted
+ * to a String. If the charsetName property is set, that character set
+ * will be used for the conversion. If the charsetName property is not
+ * set, the value of MSH-18 will be used to determine th appropriate
+ * character set. If MSH-18 is not set, then the default ASCII character
+ * set will be use.
+ *
+ * @param stringPayload
+ * enabled if true, otherwise disabled
+ */
+ private Boolean stringPayload = true;
+ /**
+ * Enable/Disable the validation of HL7 Payloads If enabled, HL7
+ * Payloads received from external systems will be validated (see
+ * Hl7Util.generateInvalidPayloadExceptionMessage for details on the
+ * validation). If and invalid payload is detected, a
+ * MllpInvalidMessageException (for consumers) or a
+ * MllpInvalidAcknowledgementException will be thrown.
+ *
+ * @param validatePayload
+ * enabled if true, otherwise disabled
+ */
+ private Boolean validatePayload = false;
+ /**
+ * Enable/Disable the validation of HL7 Payloads
+ *
+ * @deprecated the parameter will be ignored
+ * @param bufferWrites
+ * enabled if true, otherwise disabled
+ */
+ @Deprecated
+ private Boolean bufferWrites = false;
+
+ public String getCharsetName() {
+ return charsetName;
+ }
+
+ public void setCharsetName(String charsetName) {
+ this.charsetName = charsetName;
+ }
+
+ public Integer getBacklog() {
+ return backlog;
+ }
+
+ public void setBacklog(Integer backlog) {
+ this.backlog = backlog;
+ }
+
+ public Integer getBindTimeout() {
+ return bindTimeout;
+ }
+
+ public void setBindTimeout(Integer bindTimeout) {
+ this.bindTimeout = bindTimeout;
+ }
+
+ public Integer getBindRetryInterval() {
+ return bindRetryInterval;
+ }
+
+ public void setBindRetryInterval(Integer bindRetryInterval) {
+ this.bindRetryInterval = bindRetryInterval;
+ }
+
+ public Integer getAcceptTimeout() {
+ return acceptTimeout;
+ }
+
+ public void setAcceptTimeout(Integer acceptTimeout) {
+ this.acceptTimeout = acceptTimeout;
+ }
+
+ public Integer getConnectTimeout() {
+ return connectTimeout;
+ }
+
+ public void setConnectTimeout(Integer connectTimeout) {
+ this.connectTimeout = connectTimeout;
+ }
+
+ public Integer getReceiveTimeout() {
+ return receiveTimeout;
+ }
+
+ public void setReceiveTimeout(Integer receiveTimeout) {
+ this.receiveTimeout = receiveTimeout;
+ }
+
+ public Integer getMaxConcurrentConsumers() {
+ return maxConcurrentConsumers;
+ }
+
+ public void setMaxConcurrentConsumers(Integer maxConcurrentConsumers) {
+ this.maxConcurrentConsumers = maxConcurrentConsumers;
+ }
+
+ @Deprecated
+ @DeprecatedConfigurationProperty
+ public Integer getMaxReceiveTimeouts() {
+ return maxReceiveTimeouts;
+ }
+
+ @Deprecated
+ public void setMaxReceiveTimeouts(Integer maxReceiveTimeouts) {
+ this.maxReceiveTimeouts = maxReceiveTimeouts;
+ }
+
+ public Integer getIdleTimeout() {
+ return idleTimeout;
+ }
+
+ public void setIdleTimeout(Integer idleTimeout) {
+ this.idleTimeout = idleTimeout;
+ }
+
+ public Integer getReadTimeout() {
+ return readTimeout;
+ }
+
+ public void setReadTimeout(Integer readTimeout) {
+ this.readTimeout = readTimeout;
+ }
+
+ public Boolean getKeepAlive() {
+ return keepAlive;
+ }
+
+ public void setKeepAlive(Boolean keepAlive) {
+ this.keepAlive = keepAlive;
+ }
+
+ public Boolean getTcpNoDelay() {
+ return tcpNoDelay;
+ }
+
+ public void setTcpNoDelay(Boolean tcpNoDelay) {
+ this.tcpNoDelay = tcpNoDelay;
+ }
+
+ public Integer getReceiveBufferSize() {
+ return receiveBufferSize;
+ }
+
+ public void setReceiveBufferSize(Integer receiveBufferSize) {
+ this.receiveBufferSize = receiveBufferSize;
+ }
+
+ public Integer getSendBufferSize() {
+ return sendBufferSize;
+ }
+
+ public void setSendBufferSize(Integer sendBufferSize) {
+ this.sendBufferSize = sendBufferSize;
+ }
+
+ public Boolean getAutoAck() {
+ return autoAck;
+ }
+
+ public void setAutoAck(Boolean autoAck) {
+ this.autoAck = autoAck;
+ }
+
+ public Boolean getHl7Headers() {
+ return hl7Headers;
+ }
+
+ public void setHl7Headers(Boolean hl7Headers) {
+ this.hl7Headers = hl7Headers;
+ }
+
+ public Boolean getRequireEndOfData() {
+ return requireEndOfData;
+ }
+
+ public void setRequireEndOfData(Boolean requireEndOfData) {
+ this.requireEndOfData = requireEndOfData;
+ }
+
+ public Boolean getStringPayload() {
+ return stringPayload;
+ }
+
+ public void setStringPayload(Boolean stringPayload) {
+ this.stringPayload = stringPayload;
+ }
+
+ public Boolean getValidatePayload() {
+ return validatePayload;
+ }
+
+ public void setValidatePayload(Boolean validatePayload) {
+ this.validatePayload = validatePayload;
+ }
+
+ @Deprecated
+ @DeprecatedConfigurationProperty
+ public Boolean getBufferWrites() {
+ return bufferWrites;
+ }
+
+ @Deprecated
+ public void setBufferWrites(Boolean bufferWrites) {
+ this.bufferWrites = bufferWrites;
+ }
+ }
}
\ No newline at end of file
--
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <co...@camel.apache.org>'].