From dddf9202ff3fb6eaefa142dff1b107683bf44686 Mon Sep 17 00:00:00 2001
From: Simon Ebner <simon.ebner@psi.ch>
Date: Wed, 18 Dec 2013 13:08:41 +0100
Subject: [PATCH] Send EndOfStream message at the end of the stream

---
 .../src/main/java/ch/psi/fda/fdaq/FdaqService.java         | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/ch.psi.fda.fdaq/src/main/java/ch/psi/fda/fdaq/FdaqService.java b/ch.psi.fda.fdaq/src/main/java/ch/psi/fda/fdaq/FdaqService.java
index fa449c2..55b2bb4 100644
--- a/ch.psi.fda.fdaq/src/main/java/ch/psi/fda/fdaq/FdaqService.java
+++ b/ch.psi.fda.fdaq/src/main/java/ch/psi/fda/fdaq/FdaqService.java
@@ -32,6 +32,7 @@ import java.util.logging.Logger;
 import com.google.common.eventbus.EventBus;
 
 import ch.psi.fda.messages.DataMessage;
+import ch.psi.fda.messages.EndOfStreamMessage;
 import ch.psi.fda.messages.Metadata;
 
 /**
@@ -128,15 +129,15 @@ public class FdaqService {
 				bus.post(message);
 			}
 
-			out.close();
-			in.close();
-			echoSocket.close();
 		} catch (IOException e) {
 			// Ignore potential exceptions if stop was triggered before all messages were retrieved
 			if (!stopAcquisition) { 
 				throw new RuntimeException(e);
 			}
 		} finally {
+			
+			bus.post(new EndOfStreamMessage());
+			
 			try {
 				out.close();
 				in.close();