diff --git a/internal/usecases/consume/handlemessage.go b/internal/usecases/consume/handlemessage.go
index 12bf2a96007a297c5fc02b5c790eee6ab8c5d7e0..8f7148bfd527dec8b9e7e158f502d57487860dd8 100644
--- a/internal/usecases/consume/handlemessage.go
+++ b/internal/usecases/consume/handlemessage.go
@@ -72,7 +72,7 @@ func (s *Service) HandleMessage(msg *brokeradapter.Message) {
 	}
 
 	// Add type indicator to result from database
-	var res int
+	var res interface{}
 	json.Unmarshal(*result, &res)
 	resultMsgMap := make(map[string]interface{})
 	resultMsgMap["type"] = "query_result"