Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package net.bounceme.dur.driver;
- import java.io.IOException;
- import java.io.ObjectInputStream;
- import java.io.ObjectOutputStream;
- import java.net.Socket;
- import java.util.NoSuchElementException;
- import java.util.logging.Level;
- import java.util.logging.Logger;
- public class WorkerRunnable implements Runnable {
- private static final Logger log = Logger.getLogger(WorkerRunnable.class.getName());
- protected Socket socket = null;
- public WorkerRunnable(Socket clientSocket) {
- this.socket = clientSocket;
- }
- @Override
- public void run() {
- MyRecord recordFromServer = null;
- MyRecord recordFromClient = null;
- RecordsQueueWrapper recordsQueue = new RecordsQueueWrapper();
- boolean eof = false;
- recordsQueue.populate();
- try (ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
- ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream())) {
- do {
- try {
- recordFromServer = recordsQueue.pop();
- objectOutputStream.writeObject(recordFromServer);
- recordFromClient = (MyRecord) objectInputStream.readObject();
- log.info(recordFromClient.toString());
- } catch (NoSuchElementException nse) {
- eof = true;
- }
- } while (!eof);
- } catch (java.io.EOFException eofe) {
- log.warning("why is there no record from client?");
- } catch (IOException | ClassNotFoundException ex) {
- Logger.getLogger(WorkerRunnable.class.getName()).log(Level.SEVERE, null, ex);
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment