From e8b8753bd942895c37cb8783ca01a0667a68e30e Mon Sep 17 00:00:00 2001
From: Ryan <ryan@scalesec.com>
Date: Fri, 4 Jan 2019 13:18:22 -0800
Subject: [PATCH] Fixed journaller

---
 fetcher.go   | 1 +
 journaler.go | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/fetcher.go b/fetcher.go
index 32004f7..ffd9e2c 100644
--- a/fetcher.go
+++ b/fetcher.go
@@ -24,6 +24,7 @@ func NewFetcher(config *Config, sess *session.Session, journaler *Journaler) *Fe
 }
 
 func (this *Fetcher) Run() (string, error) {
+	defer this.journaler.Close()
 	var err error
 	if len(this.config.Roles) > 0 {
 		for _, role := range this.config.Roles {
diff --git a/journaler.go b/journaler.go
index 9f6b305..103413b 100644
--- a/journaler.go
+++ b/journaler.go
@@ -59,9 +59,11 @@ func (this *Journaler) listen() {
 			}
 			this.journal.Flush()
 		case <-this.quitCh:
+			fmt.Println("Closing")
 			this.fd.Close()
 			this.wg.Done()
-			return
+			break
 		}
 	}
+
 }