Fixed some merge issues.
This commit is contained in:
@@ -88,7 +88,7 @@ public class ConnectionAcceptor implements Runnable {
|
|||||||
|
|
||||||
DataOutputStream outToVisualiser = new DataOutputStream(mockSocket.getOutputStream());
|
DataOutputStream outToVisualiser = new DataOutputStream(mockSocket.getOutputStream());
|
||||||
MockOutput mockOutput = new MockOutput(latestMessages, outToVisualiser);
|
MockOutput mockOutput = new MockOutput(latestMessages, outToVisualiser);
|
||||||
ControllerServer controllerServer = new ControllerServer(mockSocket); //TODO probably pass assigned boat source ID into ControllerServer.
|
ControllerServer controllerServer = new ControllerServer(mockSocket, this.rl); //TODO probably pass assigned boat source ID into ControllerServer.
|
||||||
|
|
||||||
new Thread(mockOutput, "ConnectionAcceptor.run()->MockOutput thread" + mockOutput).start();
|
new Thread(mockOutput, "ConnectionAcceptor.run()->MockOutput thread" + mockOutput).start();
|
||||||
new Thread(controllerServer, "ConnectionAcceptor.run()->ControllerServer thread" + controllerServer).start();
|
new Thread(controllerServer, "ConnectionAcceptor.run()->ControllerServer thread" + controllerServer).start();
|
||||||
|
|||||||
@@ -72,7 +72,7 @@ public class ControllerServer extends Observable implements Runnable {
|
|||||||
try {
|
try {
|
||||||
boatActionDecoder.decode(encodedMessage.getMessageBody());
|
boatActionDecoder.decode(encodedMessage.getMessageBody());
|
||||||
BoatAction boatAction = boatActionDecoder.getMessage();
|
BoatAction boatAction = boatActionDecoder.getMessage();
|
||||||
action = boatActionDecoder.getBoatAction();
|
action = boatAction.getBoatAction();
|
||||||
|
|
||||||
// Notify observers of most recent action
|
// Notify observers of most recent action
|
||||||
this.notifyObservers();
|
this.notifyObservers();
|
||||||
|
|||||||
Reference in New Issue
Block a user