diff --git a/KvizClient/app/src/main/java/onlab/kvizclient/GameActivity.java b/KvizClient/app/src/main/java/onlab/kvizclient/GameActivity.java
index f7996b8d29ea6379e7bee1ecc000086c1d87c4a6..831898c223fc296c1ef335591cd8b3b8eac812ed 100644
--- a/KvizClient/app/src/main/java/onlab/kvizclient/GameActivity.java
+++ b/KvizClient/app/src/main/java/onlab/kvizclient/GameActivity.java
@@ -43,6 +43,7 @@ public class GameActivity extends AppCompatActivity {
             input = new BufferedReader(new InputStreamReader(ServerHolder.getSocket().getInputStream()));
             output = new PrintWriter(new BufferedWriter(
                     new OutputStreamWriter(ServerHolder.getSocket().getOutputStream())),true);
+            output.println("$$$$");
         } catch (IOException e) {
             e.printStackTrace();
         }
@@ -65,10 +66,10 @@ public class GameActivity extends AppCompatActivity {
             while (!Thread.currentThread().isInterrupted()) {
                 try {
                     String read = input.readLine();
-                    if (read != null) {
+                    if (read != null && !read.equals("$$$$")) {
                         Log.d("GameActivity", "Szervertől kapott üzenet: " + read);
                         updateConversationHandler.post(new GameActivity.updateUIThread(read));
-                        String params[] = read.split("##");
+                        //String params[] = read.split("##");
                     }
                 } catch (IOException e) {
                     Thread.currentThread().interrupt();
diff --git a/KvizServer/app/src/main/java/onlab/kvizserver/GameActivity.java b/KvizServer/app/src/main/java/onlab/kvizserver/GameActivity.java
index 080308c80e9eb73d1c1f76d1972da0a3093622c9..10753a6553be57a53d1371d1eef3e95a4a0131cf 100644
--- a/KvizServer/app/src/main/java/onlab/kvizserver/GameActivity.java
+++ b/KvizServer/app/src/main/java/onlab/kvizserver/GameActivity.java
@@ -89,6 +89,7 @@ public class GameActivity extends AppCompatActivity {
                 inputs.add(new BufferedReader(new InputStreamReader(ClientHolder.get(i).getClientsocket().getInputStream())));
                 PrintWriter output = new PrintWriter(new BufferedWriter(
                         new OutputStreamWriter(ClientHolder.get(i).getClientsocket().getOutputStream())), true);
+                output.println("$$$$");
                 outputs.add(output);
                 output.println("GameStarted");
             }
@@ -141,7 +142,7 @@ public class GameActivity extends AppCompatActivity {
             while (!Thread.currentThread().isInterrupted()) {
                 try {
                     String read = input.readLine();
-                    if (read != null) {
+                    if (read != null && !read.equals("$$$$")) {
                         Log.d("GameActivity", "Klienstől kapott üzenet: " + read);
                         updateConversationHandler.post(new GameActivity.updateUIThread(index, read));
                     }