diff --git a/Appl/CEP/CS1/CS1_InputSection/src/Connector.cc b/Appl/CEP/CS1/CS1_InputSection/src/Connector.cc
index 14b1e15f855a7c60539516d1270903f739f7f3f1..e95e1d9435e59b3a650aadc41a86cb271c13edde 100644
--- a/Appl/CEP/CS1/CS1_InputSection/src/Connector.cc
+++ b/Appl/CEP/CS1/CS1_InputSection/src/Connector.cc
@@ -67,7 +67,7 @@ namespace LOFAR {
 	theTH = new TH_Null();
       } else if (transportType=="TCP") {
 	string service = ps.getString(key + ".port");
-	if (!isReceiver) {
+	if (isReceiver) {
 	  theTH = new TH_Socket(service, 
 				true, 
 				Socket::TCP, 
@@ -83,20 +83,24 @@ namespace LOFAR {
 	}
       } else if (transportType == "UDP") {
 	string service = ps.getString(key+".port");
-	if (!isReceiver) {
+	if (isReceiver) {
 	  theTH = new TH_Socket(service,
 				true, 
 				Socket::UDP, 
-				false);
+				5,
+				false,
+				8 * 1024 * 1024, 
+				-1);
+
 	} else { 
 	  string host = ps.getString(key+".host");
 	  theTH = new TH_Socket(host, 
 				service, 
 				true, 
 				Socket::UDP, 
-				false);
-	    
-
+				false,
+				-1, 
+				8 * 1024 * 1024);
 	}
       } else {
 	ASSERTSTR(false, "TransportHolder " << transportType << " unknown to Connector");