diff --git a/internal/usecases/consume/consume_test.go b/internal/usecases/consume/consume_test.go
index f39274305b7520e159b0dd1c17172a80535fca1b..cb8f06f2259d756d96ce9ab4983b8fd82c005902 100644
--- a/internal/usecases/consume/consume_test.go
+++ b/internal/usecases/consume/consume_test.go
@@ -86,7 +86,7 @@ func TestHandleCorrectMessage(t *testing.T) {
 	var resultMessage map[string]interface{}
 	json.Unmarshal(mockBroker.Messages[mockQueue][1].Body, &resultMessage)
 	assert.Equal(t, "query_result", resultMessage["type"])
-	assert.Empty(t, resultMessage["values"])
+	assert.Equal(t, "test", resultMessage["values"])
 }
 
 // Unit test message received with no session ID
diff --git a/internal/usecases/request/mock/mockrequest.go b/internal/usecases/request/mock/mockrequest.go
index 97433b9696258c97cd20af44d22aed3129245536..7b52e4241c037e42224652b05df679d332ac56a8 100644
--- a/internal/usecases/request/mock/mockrequest.go
+++ b/internal/usecases/request/mock/mockrequest.go
@@ -19,7 +19,6 @@ func NewService() *Service {
 
 // SendAQLQuery sends the query to arangoDB and parses the result (mock)
 func (s *Service) SendAQLQuery(query string, username string, password string, hostname string, port int, database string) (*[]byte, error) {
-	//mockResult := make(map[string][]entity.Document)
 	mockResult, _ := json.Marshal("test")
 
 	if !s.throwError {