Skip to content

Commit

Permalink
Fixed some debug logging
Browse files Browse the repository at this point in the history
  • Loading branch information
Derek Collison committed Dec 19, 2014
1 parent b7932fd commit 48f6086
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
5 changes: 2 additions & 3 deletions server/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -487,10 +487,9 @@ func (c *client) unsubscribe(sub *subscription) {
c.mu.Lock()
defer c.mu.Unlock()
if sub.max > 0 && sub.nm < sub.max {
Debugf(
c.Debugf(
"Deferring actual UNSUB(%s): %d max, %d received\n",
string(sub.subject), sub.max, sub.nm, c,
)
string(sub.subject), sub.max, sub.nm)
return
}
c.traceOp("DELSUB", sub.sid)
Expand Down
2 changes: 1 addition & 1 deletion server/route.go
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ func (s *Server) sendLocalSubsToRoute(route *client) {
route.bw.Write(b.Bytes())
route.bw.Flush()

Debugf("Route sent local subscriptions", route)
route.Debugf("Route sent local subscriptions")
}

func (s *Server) createRoute(conn net.Conn, rURL *url.URL) *client {
Expand Down

0 comments on commit 48f6086

Please sign in to comment.