return ErrNotConnected

nsqio · Nov 6, 2014 · cd8e94f · cd8e94f
1 parent 5ee66d2
commit cd8e94f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/consumer.go b/consumer.go
@@ -533,7 +533,7 @@ func (r *Consumer) DisconnectFromNSQD(addr string) error {
 
 	idx := indexOf(addr, r.nsqdTCPAddrs)
 	if idx == -1 {
-		return errors.New(fmt.Sprintf("unknown nsqd TCP address %s", addr))
+		return ErrNotConnected
 	}
 
 	// slice delete
@@ -557,7 +557,7 @@ func (r *Consumer) DisconnectFromNSQLookupd(addr string) error {
 
 	idx := indexOf(addr, r.lookupdHTTPAddrs)
 	if idx == -1 {
-		return errors.New(fmt.Sprintf("unknown nsqlookupd HTTP address %s", addr))
+		return ErrNotConnected
 	}
 
 	if len(r.lookupdHTTPAddrs) == 1 {