Added debug messages
continuous-integration/drone/push Build is passing
Details
continuous-integration/drone/push Build is passing
Details
This commit is contained in:
parent
1524bbaba5
commit
b46f6df500
|
@ -86,7 +86,7 @@ func (b *Broker) Start() {
|
|||
// There is a new client attached and we
|
||||
// want to start sending them messages.
|
||||
b.clients[s] = true
|
||||
log.Info("Added new client")
|
||||
log.Debug("Added new client")
|
||||
|
||||
case s := <-b.defunctClients:
|
||||
|
||||
|
@ -95,7 +95,7 @@ func (b *Broker) Start() {
|
|||
delete(b.clients, s)
|
||||
close(s)
|
||||
|
||||
log.Info("Removed client")
|
||||
log.Debug("Removed client")
|
||||
|
||||
case msg := <-b.messages:
|
||||
|
||||
|
@ -138,7 +138,7 @@ func (b *Broker) Serve(c echo.Context) error {
|
|||
// Remove this client from the map of attached clients
|
||||
// when `EventHandler` exits.
|
||||
b.defunctClients <- messageChan
|
||||
log.Info("HTTP connection closed.")
|
||||
log.Debug("HTTP connection closed.")
|
||||
}()
|
||||
|
||||
// Set the headers related to event streaming.
|
||||
|
@ -174,7 +174,7 @@ func (b *Broker) Serve(c echo.Context) error {
|
|||
}
|
||||
|
||||
// Done.
|
||||
log.Info("Finished HTTP request")
|
||||
log.Debug("Finished HTTP request")
|
||||
return nil
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue