error handling
This commit is contained in:
@ -78,17 +78,17 @@ func main() {
|
|||||||
event.Latitude = req.Form.Get("latitude")
|
event.Latitude = req.Form.Get("latitude")
|
||||||
event.Longitude = req.Form.Get("longitude")
|
event.Longitude = req.Form.Get("longitude")
|
||||||
|
|
||||||
var message string
|
|
||||||
select {
|
select {
|
||||||
case ch <- event:
|
case ch <- event:
|
||||||
message = "message forwarded"
|
resp.WriteHeader(http.StatusOK)
|
||||||
|
fmt.Fprintf(resp, "Message forwarded")
|
||||||
|
return
|
||||||
default:
|
default:
|
||||||
log.Println("Channel full, message lost")
|
log.Printf("Channel full, message lost")
|
||||||
message = "message lost"
|
http.Error(resp, "Channel full, message lost", http.StatusServiceUnavailable)
|
||||||
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
resp.WriteHeader(http.StatusOK)
|
|
||||||
fmt.Fprintf(resp, message)
|
|
||||||
})
|
})
|
||||||
|
|
||||||
err := http.ListenAndServe(":8080", nil)
|
err := http.ListenAndServe(":8080", nil)
|
||||||
|
Reference in New Issue
Block a user