diff --git a/src/chat/ReceiveThread.java b/src/chat/ReceiveThread.java
index fb31602..57aff9c 100644
--- a/src/chat/ReceiveThread.java
+++ b/src/chat/ReceiveThread.java
@@ -37,12 +37,13 @@ class ReceiveThread extends Thread {
 	}
 	public void run()
 	{
+		ObjectInputStream in;
 		boolean exit = false;
 		while(!exit)
 		{
 			try
 			{
-				ObjectInputStream in = new ObjectInputStream(socket.getInputStream());
+				in = new ObjectInputStream(socket.getInputStream());
 		        Notification notif = (Notification) in.readObject();
 		        
 		        if(!(notif.getAuthor().equals(user)) && !(notif.getAuthor().isOutdoor() && !isOutdoor))
@@ -140,6 +141,7 @@ class ReceiveThread extends Thread {
 			}
 			catch(Exception e)
 	    	{
+				in.reset();
 				e.printStackTrace();
 				/*System.out.println("Socket closed");
 	        	dest_sockets.remove(socket);