diff --git a/client/src/main/java/envoy/client/net/Receiver.java b/client/src/main/java/envoy/client/net/Receiver.java index e325c4f..fdfa1e8 100644 --- a/client/src/main/java/envoy/client/net/Receiver.java +++ b/client/src/main/java/envoy/client/net/Receiver.java @@ -1,8 +1,6 @@ package envoy.client.net; -import java.io.ByteArrayInputStream; -import java.io.InputStream; -import java.io.ObjectInputStream; +import java.io.*; import java.net.SocketException; import java.util.HashMap; import java.util.Map; @@ -82,8 +80,9 @@ public class Receiver extends Thread { logger.log(Level.WARNING, String.format("The received object has the %s for which no processor is defined.", obj.getClass())); else processor.accept(obj); } - } catch (final SocketException e) { + } catch (final SocketException | EOFException e) { // Connection probably closed by client. + logger.log(Level.FINER, "Exiting receiver..."); return; } catch (final Exception e) { logger.log(Level.SEVERE, "Error on receiver thread", e);