From df2618e13546c727895cf8038b273a778ba04182 Mon Sep 17 00:00:00 2001
From: Christoph Schulthess
Date: Mon, 13 Feb 2017 13:18:26 +0100
Subject: DispatchRelay class/task sockets fixed

---
 src/main/java/org/openslx/taskmanager/tasks/DispatchRelay.java | 5 +++--
 1 file 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;
 	}
-- 
cgit v1.2.3-55-g7522