1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.mina.examples.sumup.codec;
20
21 import org.apache.mina.common.ByteBuffer;
22 import org.apache.mina.common.IoSession;
23 import org.apache.mina.examples.sumup.message.AbstractMessage;
24 import org.apache.mina.examples.sumup.message.AddMessage;
25 import org.apache.mina.filter.codec.demux.MessageDecoder;
26
27 /***
28 * A {@link MessageDecoder} that decodes {@link AddMessage}.
29 *
30 * @author The Apache Directory Project
31 * @version $Rev: 355016 $, $Date: 2005-12-08 16:00:30 +0900 (Thu, 08 Dec 2005) $
32 */
33 public class AddMessageDecoder extends AbstractMessageDecoder
34 {
35
36 public AddMessageDecoder()
37 {
38 super( Constants.ADD );
39 }
40
41 protected AbstractMessage decodeBody( IoSession session, ByteBuffer in )
42 {
43 if( in.remaining() < Constants.ADD_BODY_LEN )
44 {
45 return null;
46 }
47
48 AddMessage m = new AddMessage();
49 m.setValue( in.getInt() );
50 return m;
51 }
52
53 public void dispose() throws Exception
54 {
55 }
56 }