Author: norman
Date: Tue Nov 16 20:40:09 2010
New Revision: 1035794
URL: http://svn.apache.org/viewvc?rev=1035794&view=rev
Log:
Share outputstream on channel per session
Modified:
james/server/trunk/pop3server/src/main/java/org/apache/james/pop3server/netty/POP3NettySession.java
Modified:
james/server/trunk/pop3server/src/main/java/org/apache/james/pop3server/netty/POP3NettySession.java
URL:
http://svn.apache.org/viewvc/james/server/trunk/pop3server/src/main/java/org/apache/james/pop3server/netty/POP3NettySession.java?rev=1035794&r1=1035793&r2=1035794&view=diff
==============================================================================
---
james/server/trunk/pop3server/src/main/java/org/apache/james/pop3server/netty/POP3NettySession.java
(original)
+++
james/server/trunk/pop3server/src/main/java/org/apache/james/pop3server/netty/POP3NettySession.java
Tue Nov 16 20:40:09 2010
@@ -44,15 +44,17 @@ public class POP3NettySession extends Ab
private MessageManager mailbox;
+ private NonClosingChannelOutputStream out;
+
public POP3NettySession(POP3HandlerConfigurationData configData, Log
logger, ChannelHandlerContext handlerContext) {
- super(logger, handlerContext);
- this.configData = configData;
+ this(configData, logger, handlerContext, null);
}
public POP3NettySession(POP3HandlerConfigurationData configData, Log
logger, ChannelHandlerContext handlerContext, SSLEngine engine) {
super(logger, handlerContext, engine);
this.configData = configData;
+ this.out = new
NonClosingChannelOutputStream(getChannelHandlerContext().getChannel());
}
@@ -125,7 +127,7 @@ public class POP3NettySession extends Ab
* @see org.apache.james.pop3server.POP3Session#getOutputStream()
*/
public OutputStream getOutputStream() {
- return new
NonClosingChannelOutputStream(getChannelHandlerContext().getChannel());
+ return out;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
