Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
144f8412fa
|
@ -78,17 +78,17 @@ func main() {
|
||||
event.Latitude = req.Form.Get("latitude")
|
||||
event.Longitude = req.Form.Get("longitude")
|
||||
|
||||
var message string
|
||||
select {
|
||||
case ch <- event:
|
||||
message = "message forwarded"
|
||||
resp.WriteHeader(http.StatusOK)
|
||||
fmt.Fprintf(resp, "Message forwarded")
|
||||
return
|
||||
default:
|
||||
log.Println("Channel full, message lost")
|
||||
message = "message lost"
|
||||
log.Printf("Channel full, 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)
|
||||
|
Reference in New Issue
Block a user