diff options
| -rw-r--r-- | src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java b/src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java index 4c0f6e9..470134d 100644 --- a/src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java +++ b/src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java @@ -55,7 +55,7 @@ public class DispatchRelay extends AbstractTask { } status.addMessage( "Sockets closed properly." ); } catch ( IOException iox ) { - status.addMessage( "Failed to close Sockets." + iox.getMessage() ); + status.addMessage( "Failed to close Sockets. " + iox.getMessage() ); } } return true; @@ -77,9 +77,10 @@ public class DispatchRelay extends AbstractTask { protected Thread[] createRelayThreads ( Socket[] sockets) throws IOException { Thread[] t = new Thread[2]; + Socket[][] s = {sockets, {sockets[1], sockets[0]}}; for ( int i = 0; i < 2; i++ ) { - t[i] = new Thread( new Relay( sockets, status, descs[i] )); + t[i] = new Thread( new Relay( s[i], status, descs[i] )); } return t; } |