ActionMessenger.java

package edu.stanford.hci.r3.actions.remote;

import java.io.BufferedOutputStream;
import java.io.IOException;
import java.net.Socket;

import edu.stanford.hci.r3.actions.R3Action;
import edu.stanford.hci.r3.util.DebugUtils;
import edu.stanford.hci.r3.util.SystemUtils;

public abstract class ActionMessenger {

        protected static final String LINE_SEPARATOR = SystemUtils.LINE_SEPARATOR;

        private BufferedOutputStream bos;

        private Socket sock;

        public ActionMessenger(Socket s) {
                try {
                        sock = s;
                        bos = new BufferedOutputStream(s.getOutputStream());
                } catch (IOException e) {
                        e.printStackTrace();
                }
        }

        public void destroy() {
                try {
                        if (bos != null) {
                                bos.close();
                                bos = null;
                        }
                        if (sock != null) {
                                sock.close();
                                sock = null;
                        }
                } catch (IOException ioe) {
                        DebugUtils.println("Got exception when destroying messenger: "
                                        + ioe.getLocalizedMessage());
                }
        }

        public abstract byte[] getMessage(R3Action action);

        public void sendAction(R3Action action) {
                try {
                        bos.write(getMessage(action));
                        bos.flush();
                } catch (IOException e) {
                        e.printStackTrace();
                }
        }

}

---