diff --git a/internal/consumer/consumer.go b/internal/consumer/consumer.go
index 61f073e..ca68588 100644
--- a/internal/consumer/consumer.go
+++ b/internal/consumer/consumer.go
@@ -17,6 +17,7 @@ func Consume(dependency *dependency.Dependency) {
 		msg := <-sub.C
 
 		if msg != nil {
+			log.Println("Received message from queue")
 			go RunJob(msg, dependency)
 		}
 	}
diff --git a/internal/consumer/job.go b/internal/consumer/job.go
index b653e6e..fdff477 100644
--- a/internal/consumer/job.go
+++ b/internal/consumer/job.go
@@ -57,6 +57,8 @@ func RunJob(msg *stomp.Message, dependency *dependency.Dependency) {
 		return
 	}
 
+	log.Println("Received file to transcode with id: ", value.FileId)
+
 	var id int64
 	err = dependency.DBConn.QueryRow(insertQuery, value.FileId, Started.string()).Scan(&id)
 	if err != nil {
@@ -126,6 +128,8 @@ func RunJob(msg *stomp.Message, dependency *dependency.Dependency) {
 	if err != nil {
 		log.Println(err)
 	}
+
+	log.Println("Finished processing for fileId: ", value.FileId)
 }
 
 func encodeVideoAndUploadToS3(target int, object string, channel chan EncoderResponse, dependency *dependency.Dependency) {
diff --git a/internal/encoder/encoder.go b/internal/encoder/encoder.go
index 40571f4..b50446a 100644
--- a/internal/encoder/encoder.go
+++ b/internal/encoder/encoder.go
@@ -2,7 +2,6 @@ package encoder
 
 import (
 	"fmt"
-	"log"
 	"os/exec"
 	"time"
 )
@@ -14,7 +13,7 @@ func EncodeVideo(input string, target int) (string, error) {
 		"-c:v", "libx264", "-crf", "18", "-preset", "veryslow",
 		"-c:a", "copy", fmt.Sprintf("./files/%s", key))
 
-	cmd.Stderr = log.Writer()
+	cmd.Stdout = nil
 
 	err := cmd.Run()
 	if err != nil {