public function disconnectFromNSQD($host, $port)
    {
        $key = "$host:$port";
        if (!isset($this->nsqdTCPAddrsConnNum[$key])) {
            throw new NsqException("not connected");
        }

        foreach ($this->getConnections() as $conn) {
            if ($conn->getHost() === $host && $conn->getPort() === $port) {
                $conn->tryClose();
            }
        }
        $this->nsqdTCPAddrsConnNum[$key] = 0;
    }
public function disconnectFromNSQD($host, $port)
    {
        $key = "$host:$port";
        if (!isset($this->nsqdTCPAddrsConnNum[$key])) {
            throw new NsqException("not connected");
        }

        foreach ($this->getConnections() as $conn) {
            if ($conn->getHost() === $host && $conn->getPort() === $port) {
                $conn->tryClose();
            }
        }
        $this->nsqdTCPAddrsConnNum[$key] = 0;
    }
public function disconnectFromNSQD ( $ host , $ port ) { $ key = "$host:$port" ; if ( ! isset ( $ this -> nsqdTCPAddrsConnNum [ $ key ] ) ) { throw new NsqException ( "not connected" ) ; } foreach ( $ this -> getConnections ( ) as $ conn ) { if ( $ conn -> getHost ( ) === $ host && $ conn -> getPort ( ) === $ port ) { $ conn -> tryClose ( ) ; } } $ this -> nsqdTCPAddrsConnNum [ $ key ] = 0 ; }
DisconnectFromNSQD closes the connection to and removes the specified
`nsqd` address from the list
@param string $host
@param int $port
@return void
@throws NsqException
DisconnectFromNSQD closes the connection to and removes the specified nsqd address from the list