Author: davsclaus
Date: Tue Jul 6 05:54:38 2010
New Revision: 960796
URL: http://svn.apache.org/viewvc?rev=960796&view=rev
Log:
CAMEL-2908: Added textline delimiter configuration and auto append missing
delimiter options.
Modified:
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
Modified:
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java?rev=960796&r1=960795&r2=960796&view=diff
==============================================================================
---
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
(original)
+++
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
Tue Jul 6 05:54:38 2010
@@ -56,7 +56,7 @@ public class NettyConfiguration implemen
private boolean textline;
private TextLineDelimiter delimiter = TextLineDelimiter.LINE;
private boolean autoAppendDelimiter = true;
- private int decorderMaxLineLength = 1024;
+ private int decoderMaxLineLength = 1024;
private String encoding;
private String passphrase;
private File keyStoreFile;
@@ -128,12 +128,12 @@ public class NettyConfiguration implemen
if (isTextline()) {
Charset charset = getEncoding() != null ?
Charset.forName(getEncoding()) : CharsetUtil.UTF_8;
encoders.add(new StringEncoder(charset));
- decoders.add(new
DelimiterBasedFrameDecoder(decorderMaxLineLength, true, delimiter ==
TextLineDelimiter.LINE ? Delimiters.lineDelimiter() :
Delimiters.nulDelimiter()));
+ decoders.add(new
DelimiterBasedFrameDecoder(decoderMaxLineLength, true, delimiter ==
TextLineDelimiter.LINE ? Delimiters.lineDelimiter() :
Delimiters.nulDelimiter()));
decoders.add(new StringDecoder(charset));
if (LOG.isDebugEnabled()) {
LOG.debug("Using textline encoders and decoders with
charset: " + charset + ", delimiter: "
- + delimiter + " and decoderMaxLineLength: " +
decorderMaxLineLength);
+ + delimiter + " and decoderMaxLineLength: " +
decoderMaxLineLength);
}
} else {
// object serializable is then used
@@ -249,12 +249,12 @@ public class NettyConfiguration implemen
this.textline = textline;
}
- public int getDecorderMaxLineLength() {
- return decorderMaxLineLength;
+ public int getDecoderMaxLineLength() {
+ return decoderMaxLineLength;
}
- public void setDecorderMaxLineLength(int decorderMaxLineLength) {
- this.decorderMaxLineLength = decorderMaxLineLength;
+ public void setDecoderMaxLineLength(int decoderMaxLineLength) {
+ this.decoderMaxLineLength = decoderMaxLineLength;
}
public TextLineDelimiter getDelimiter() {
