Author: norman
Date: Sat Jan 15 09:56:14 2011
New Revision: 1059278
URL: http://svn.apache.org/viewvc?rev=1059278&view=rev
Log:
Append command now work with push model
Modified:
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/decode/parser/AppendCommandParser.java
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/AbstractImapResponseComposer.java
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/ChannelImapResponseComposer.java
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/main/AbstractImapRequestHandler.java
Modified:
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/decode/parser/AppendCommandParser.java
URL:
http://svn.apache.org/viewvc/james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/decode/parser/AppendCommandParser.java?rev=1059278&r1=1059277&r2=1059278&view=diff
==============================================================================
---
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/decode/parser/AppendCommandParser.java
(original)
+++
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/decode/parser/AppendCommandParser.java
Sat Jan 15 09:56:14 2011
@@ -137,7 +137,7 @@ public class AppendCommandParser extends
session.setAttribute(ImapConstants.NEXT_DECODER, nextDecoder);
- return new ContinuationRequest(command, tag, nextDecoder);
+ return null;
} catch (IOException e1) {
e1.printStackTrace();
Modified:
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/AbstractImapResponseComposer.java
URL:
http://svn.apache.org/viewvc/james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/AbstractImapResponseComposer.java?rev=1059278&r1=1059277&r2=1059278&view=diff
==============================================================================
---
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/AbstractImapResponseComposer.java
(original)
+++
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/AbstractImapResponseComposer.java
Sat Jan 15 09:56:14 2011
@@ -339,10 +339,11 @@ public abstract class AbstractImapRespon
/*
* (non-Javadoc)
- * @see
org.apache.james.imap.encode.ImapResponseWriter#commandContinuationRequest()
+ * @see org.apache.james.imap.encode.ImapResponseWriter#()
*/
public void commandContinuationRequest() throws IOException {
- writeASCII(CONTINUATION + SP);
+ writeASCII(CONTINUATION);
+ end();
}
Modified:
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/ChannelImapResponseComposer.java
URL:
http://svn.apache.org/viewvc/james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/ChannelImapResponseComposer.java?rev=1059278&r1=1059277&r2=1059278&view=diff
==============================================================================
---
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/ChannelImapResponseComposer.java
(original)
+++
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/encode/base/ChannelImapResponseComposer.java
Sat Jan 15 09:56:14 2011
@@ -46,6 +46,7 @@ public class ChannelImapResponseComposer
* @see
org.apache.james.imap.encode.base.AbstractImapResponseComposer#write(java.nio.ByteBuffer)
*/
protected void write(final ByteBuffer buffer) throws IOException {
+ //System.err.print(new String(buffer.array()));
while (out.write(buffer) > 0) {
// Write all
}
Modified:
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/main/AbstractImapRequestHandler.java
URL:
http://svn.apache.org/viewvc/james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/main/AbstractImapRequestHandler.java?rev=1059278&r1=1059277&r2=1059278&view=diff
==============================================================================
---
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/main/AbstractImapRequestHandler.java
(original)
+++
james/imap/branches/nio-refactoring/message/src/main/java/org/apache/james/imap/main/AbstractImapRequestHandler.java
Sat Jan 15 09:56:14 2011
@@ -65,7 +65,7 @@ public abstract class AbstractImapReques
if (message != null) {
final ResponseEncoder responseEncoder = new
ResponseEncoder(encoder, response, session);
processor.process(message, responseEncoder, session);
-
+
final boolean result;
final IOException failure = responseEncoder.getFailure();
if (failure == null) {
@@ -78,6 +78,7 @@ public abstract class AbstractImapReques
logger.debug("Failed to write " + message, failure);
}
}
+
return result;
}
return true;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
