raise FATAL in receiver on hertbeat timeout

kelvich · kelvich · commit ed48019db00f · 2019-03-19T17:50:19.000+03:00
diff --git a/src/dmq.c b/src/dmq.c
@@ -1139,7 +1139,7 @@ dmq_receiver_loop(PG_FUNCTION_ARGS)
 
 		if (dmq_now() - last_message_at > recv_timeout)
 		{
-			mtm_log(ERROR, "[DMQ] exit receiver due to heatbeat timeout");
+			mtm_log(FATAL, "[DMQ] exit receiver due to heatbeat timeout");
 		}
 
 	}

Original file line number	Diff line number	Diff line change
`@@ -1139,7 +1139,7 @@ dmq_receiver_loop(PG_FUNCTION_ARGS)`
`1139`	`1139`
`1140`	`1140`	`if (dmq_now() - last_message_at > recv_timeout)`
`1141`	`1141`	`{`
`1142`		`- mtm_log(ERROR, "[DMQ] exit receiver due to heatbeat timeout");`
	`1142`	`+ mtm_log(FATAL, "[DMQ] exit receiver due to heatbeat timeout");`
`1143`	`1143`	`}`
`1144`	`1144`
`1145`	`1145`	`}`