Added panic intercept method to RabbitMQ message handler

Fix for issue graphpolaris/central-ideas-issues#40 (closed)

internal/usecases/consume/handlemessage.go

@@ -24,6 +24,7 @@ HandleMessage gets called when a message is received
 	msg: *broker.Message, the message to be handled
 */
 func (s *Service) HandleMessage(msg *broker.Message) {
+
 	// Grab the headers from the message
 	sessionID, clientID, queryID, err := getHeaders(&msg.Headers)
 	if err != nil {
@@ -32,6 +33,15 @@ func (s *Service) HandleMessage(msg *broker.Message) {
 	}
 	s.publishStatus("Received", sessionID, queryID)
 
+	// Defer a panic intercepting function
+	defer func(sessionID, queryID *string) {
+		if err := recover(); err != nil {
+			log.Printf("PANIC: %e", err.(error))
+
+			s.publishStatus("Critical Error", sessionID, queryID)
+		}
+	}(sessionID, queryID)
+
 	// Unmarshall the incoming message into an IncomingJSONQuery object
 	JSONQuery, err := query.UnmarshalJSON(&msg.Body)
 	if err != nil {