KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > ubermq > jms > server > proc > OutputMessageProcessor


1 package com.ubermq.jms.server.proc;
2
3 import java.nio.*;
4 import com.ubermq.kernel.IDatagram;
5
6 /**
7  * A simple message processor that outputs the binary representation
8  * of all bytes sent to it.
9  */
10 public class OutputMessageProcessor implements com.ubermq.kernel.IMessageProcessor
11 {
12     private StringBuffer JavaDoc sb = new StringBuffer JavaDoc();
13
14     public void accept(com.ubermq.kernel.IConnectionInfo ci)
15     {
16     }
17
18     public void remove(com.ubermq.kernel.IConnectionInfo ci)
19     {
20     }
21
22     public void process(com.ubermq.kernel.IConnectionInfo ci, IDatagram d)
23     {
24         CharBuffer cb = CharBuffer.wrap(d.toString().toCharArray());
25         char[] ch = new char[cb.remaining()];
26         cb.get(ch);
27
28         sb.setLength(0);
29         sb.append(ch);
30         System.out.println(sb.toString());
31     }
32 }
33
Popular Tags