Author: norman
Date: Wed Jun 22 18:38:39 2011
New Revision: 1138574
URL: http://svn.apache.org/viewvc?rev=1138574&view=rev
Log:
Fix problem with PIPELINE support when using NIO version of SMTPServer. See
JAMES-1277
Modified:
james/server/trunk/smtpserver/src/main/java/org/apache/james/smtpserver/netty/SMTPNettySession.java
Modified:
james/server/trunk/smtpserver/src/main/java/org/apache/james/smtpserver/netty/SMTPNettySession.java
URL:
http://svn.apache.org/viewvc/james/server/trunk/smtpserver/src/main/java/org/apache/james/smtpserver/netty/SMTPNettySession.java?rev=1138574&r1=1138573&r2=1138574&view=diff
==============================================================================
---
james/server/trunk/smtpserver/src/main/java/org/apache/james/smtpserver/netty/SMTPNettySession.java
(original)
+++
james/server/trunk/smtpserver/src/main/java/org/apache/james/smtpserver/netty/SMTPNettySession.java
Wed Jun 22 18:38:39 2011
@@ -116,8 +116,11 @@ public class SMTPNettySession extends Ab
*/
public void pushLineHandler(LineHandler<SMTPSession>
overrideCommandHandler) {
lineHandlerCount++;
-
- getChannelHandlerContext().getPipeline().addAfter("timeoutHandler",
"lineHandler" + lineHandlerCount, new
LineHandlerUpstreamHandler<SMTPSession>(overrideCommandHandler));
+ // Add the linehandler in front of the coreHandler so we can be sure
+ // it is executed with the same ExecutorHandler as the coreHandler (if
one exist)
+ //
+ // See JAMES-1277
+ getChannelHandlerContext().getPipeline().addBefore("coreHandler",
"lineHandler" + lineHandlerCount, new
LineHandlerUpstreamHandler<SMTPSession>(overrideCommandHandler));
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
