You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2010/07/06 07:54:38 UTC
svn commit: r960796 -
/camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
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() {