Debugging: kill process immediately a heartbeat error is detected (systemd will restart it soon thereafter)

1 files changed, 2 insertions, 0 deletions

diff --git a/cmd/bookpipeline/main.go b/cmd/bookpipeline/main.go
index f7da588..3f8303f 100644
--- a/cmd/bookpipeline/main.go
+++ b/cmd/bookpipeline/main.go
@@ -255,6 +255,8 @@ func heartbeat(conn Pipeliner, t *time.Ticker, msg bookpipeline.Qmsg, queue stri
 	for range t.C {
 		m, err := conn.QueueHeartbeat(currentmsg, queue, HeartbeatTime*2)
 		if err != nil {
+			// This is for better debugging of the heartbeat issue
+			os.Exit(1)
 			// TODO: would be better to ensure this error stops any running
 			//       processes, as they will ultimately fail in the case of
 			//       it. could do this by setting a global variable that