Browse Source

Add basic logging to broker connection management.

Willem van Bergen 12 years ago
parent
commit
3833132543
2 changed files with 4 additions and 2 deletions
  1. 2 2
      broker.go
  2. 2 0
      client.go

+ 2 - 2
broker.go

@@ -83,9 +83,9 @@ func (b *Broker) Close() (err error) {
 	defer b.lock.Unlock()
 	defer b.lock.Unlock()
 	defer func() {
 	defer func() {
 		if err == nil {
 		if err == nil {
-			Logger.Printf("Closed connection to broker #%d %s\n", b.id, b.addr)
+			Logger.Printf("Closed connection to broker %s\n", b.addr)
 		} else {
 		} else {
-			Logger.Printf("Failed to close connection to broker #%d %s.\n", b.id, b.addr)
+			Logger.Printf("Failed to close connection to broker %s.\n", b.addr)
 			Logger.Println(err)
 			Logger.Println(err)
 		}
 		}
 	}()
 	}()

+ 2 - 0
client.go

@@ -270,10 +270,12 @@ func (client *Client) update(data *MetadataResponse) ([]string, error) {
 		if client.brokers[broker.ID()] == nil {
 		if client.brokers[broker.ID()] == nil {
 			broker.Open()
 			broker.Open()
 			client.brokers[broker.ID()] = broker
 			client.brokers[broker.ID()] = broker
+			Logger.Printf("Registered new broker #%d at %s", broker.ID(), broker.Addr())
 		} else if broker.Addr() != client.brokers[broker.ID()].Addr() {
 		} else if broker.Addr() != client.brokers[broker.ID()].Addr() {
 			go client.brokers[broker.ID()].Close()
 			go client.brokers[broker.ID()].Close()
 			broker.Open()
 			broker.Open()
 			client.brokers[broker.ID()] = broker
 			client.brokers[broker.ID()] = broker
+			Logger.Printf("Replaced registered broker #%d with %s", broker.ID(), broker.Addr())
 		}
 		}
 	}
 	}