|
@@ -52,7 +52,7 @@ type responsePromise struct {
|
|
|
errors chan error
|
|
errors chan error
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// NewBroker creates and returns a Broker targetting the given host:port address.
|
|
|
|
|
|
|
+// NewBroker creates and returns a Broker targeting the given host:port address.
|
|
|
// This does not attempt to actually connect, you have to call Open() for that.
|
|
// This does not attempt to actually connect, you have to call Open() for that.
|
|
|
func NewBroker(addr string) *Broker {
|
|
func NewBroker(addr string) *Broker {
|
|
|
return &Broker{id: -1, addr: addr}
|
|
return &Broker{id: -1, addr: addr}
|