Remove ack crap (rethining this)
Этот коммит содержится в:
родитель
c76ef2f61d
Коммит
a56c04cbbe
|
@ -11,12 +11,6 @@ type Message struct {
|
|||
Topic string `json:"topic"`
|
||||
Payload []byte `json:"payload"`
|
||||
Created time.Time `json:"created"`
|
||||
Acked time.Time `json:"acked"`
|
||||
}
|
||||
|
||||
// Ack ...
|
||||
type Ack struct {
|
||||
Ack uint64 `json:"ack"`
|
||||
}
|
||||
|
||||
// Listeners ...
|
||||
|
|
13
server.go
13
server.go
|
@ -76,10 +76,7 @@ func (s *Server) PushWebSocketHandler(topic string) websocket.Handler {
|
|||
s.bus.Unsubscribe(id, topic)
|
||||
}()
|
||||
|
||||
var (
|
||||
err error
|
||||
ack Ack
|
||||
)
|
||||
var err error
|
||||
|
||||
for {
|
||||
msg := <-ch
|
||||
|
@ -88,14 +85,6 @@ func (s *Server) PushWebSocketHandler(topic string) websocket.Handler {
|
|||
log.Printf("Error sending msg to %s", id)
|
||||
continue
|
||||
}
|
||||
|
||||
err = websocket.JSON.Receive(conn, &ack)
|
||||
if err != nil {
|
||||
log.Printf("Error receiving ack from %s", id)
|
||||
continue
|
||||
}
|
||||
|
||||
log.Printf("message %v acked %v by %s", msg, ack, id)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Загрузка…
Ссылка в новой задаче