.gitignore

@@ -1 +0,0 @@
-queues-go

app/routers/put.go

@@ -21,7 +21,6 @@ func Put(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(http.StatusBadRequest)
 		return
 	}
-
 	queue := r.Header.Get("queue")
 	var availableFrom time.Time
 	if body.Delay == nil {
@@ -29,7 +28,6 @@ func Put(w http.ResponseWriter, r *http.Request) {
 	} else {
 		availableFrom = time.Now().Add(time.Second + time.Duration(*body.Delay))
 	}
-
 	task := tasks.InsertedTask{
 		Queue:            queue,
 		Payload:          body.Payload,
@@ -39,12 +37,10 @@ func Put(w http.ResponseWriter, r *http.Request) {
 		TakenAt:          nil,
 		Attempts:         0,
 	}
-
 	err = tasks.Add(task)
 	if err != nil {
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
-
 	w.WriteHeader(http.StatusAccepted)
 }

app/routers/take.go

@@ -23,7 +23,6 @@ func Take(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
-
 	var response TakeResponse
 	if task == nil {
 		response.Task = nil
@@ -34,12 +33,10 @@ func Take(w http.ResponseWriter, r *http.Request) {
 			Payload: task.Payload,
 		}
 	}
-
 	data, err := json.Marshal(response)
 	if err != nil {
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
-
 	w.Write(data)
 }