diff --git a/src/entry_stream.rs b/src/entry_stream.rs
index 31086ab2ca..61e641bef4 100644
--- a/src/entry_stream.rs
+++ b/src/entry_stream.rs
@@ -47,10 +47,13 @@ pub struct EntrySocket {
     socket: String,
 }
 
+const MESSAGE_TERMINATOR: &str = "\n";
+
 impl EntryWriter for EntrySocket {
     fn write(&self, payload: String) -> Result<()> {
         let mut socket = UnixStream::connect(Path::new(&self.socket))?;
         socket.write_all(payload.as_bytes())?;
+        socket.write_all(MESSAGE_TERMINATOR.as_bytes())?;
         socket.shutdown(Shutdown::Write)?;
         Ok(())
     }