View Javadoc

1   /*
2    * Wallace IMAP Server
3    * Copyright (C) 2004  Robert Newson
4    *
5    * This program is free software; you can redistribute it and/or
6    * modify it under the terms of the GNU General Public License
7    * as published by the Free Software Foundation; either version 2
8    * of the License, or (at your option) any later version.
9    *
10   * This program is distributed in the hope that it will be useful,
11   * but WITHOUT ANY WARRANTY; without even the implied warranty of
12   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13   * GNU General Public License for more details.
14   *
15   * You should have received a copy of the GNU General Public License
16   * along with this program; if not, write to the Free Software
17   * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
18   */
19  package net.sf.wallace.mina;
20  
21  import java.io.UnsupportedEncodingException;
22  
23  import net.sf.wallace.ServerResponse;
24  
25  import org.apache.mina.common.ByteBuffer;
26  import org.apache.mina.protocol.ProtocolEncoder;
27  import org.apache.mina.protocol.ProtocolEncoderOutput;
28  import org.apache.mina.protocol.ProtocolSession;
29  import org.apache.mina.protocol.ProtocolViolationException;
30  
31  /***
32   * IMAP4 protocol encoder.
33   * 
34   * @author rnewson
35   */
36  public final class IMAP4ProtocolEncoder implements ProtocolEncoder {
37  
38      public void encode(final ProtocolSession protocolSession, final Object object, final ProtocolEncoderOutput output)
39              throws ProtocolViolationException {
40          assert protocolSession != null;
41          assert object instanceof ServerResponse : "IMAP4ProtocolEncoder can only encode ServerResponse objects";
42          final ServerResponse message = (ServerResponse) object;
43  
44          final String val = message.toString();
45          final ByteBuffer buffer = ByteBuffer.allocate(val.length());
46          try {
47              buffer.put(val.getBytes("US-ASCII"));
48          } catch (UnsupportedEncodingException e) {
49              throw new ProtocolViolationException("Unable to convert to ASCII.", e);
50          }
51          buffer.flip();
52          output.write(buffer);
53      }
54  
55  }