package network.jms; import gui.Lab; import java.net.Socket; import java.util.logging.Logger; import network.MessageGenerator; import network.MessageType; import server.jms.JmsConnection; /** * * @author Mark */ public class RequestSender { private static final Logger LOG = Logger.getLogger(RequestSender.class.getName()); private final MessageGenerator messageGenerator = new MessageGenerator(); private final Lab lab; private final String machineId; public RequestSender(final Lab lab, String machineId) { this.lab = lab; this.machineId = machineId; } public void sendRequest(final MessageType type) { JmsConnection connection = new JmsConnection(); if(type == MessageType.HELP ) { connection.sendMessageToTopic(lab.getLabName()+"_help", machineId); } else if (type == MessageType.MARKING) { connection.sendMessageToTopic(lab.getLabName()+"_marking", machineId); } } // @SuppressWarnings({"rawtypes", "unchecked"}) // public Collection<Integer> requestQueue() { // try { // final Socket socket = new Socket(destinationIp, Constants.PORT); // final PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); // writer.println(messageGenerator.requestQueue()); // writer.flush(); // final ObjectInputStream ois = new ObjectInputStream(socket.getInputStream()); // final Collection<Integer> response = (Collection<Integer>) ois.readObject(); // writer.close(); // ois.close(); // socket.close(); // return response; // } catch (Exception ex) { // LOG.log(Level.SEVERE, null, ex); // } // return Collections.EMPTY_SET; // } @SuppressWarnings({"rawtypes", "unchecked"}) public Socket registerTutorClient() { // try { // final Socket socket = new Socket(destinationIp, Constants.PORT); // final PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); // // writer.println(messageGenerator.registerTutorClient()); // writer.flush(); // // return socket; // } catch (Exception ex) { // LOG.log(Level.SEVERE, "Error registering tutor client", ex); // } return null; } }