src/Producer.php
public function close(): void
    {
        if ($this->closed) {
            return;
        }

        $this->emit('end', [$this]);
        $this->loop->cancelTimer($this->timer);
        $this->removeAllListeners();
        $this->exchange = null;
        $this->closed = true;
    }
public function close(): void
    {
        if ($this->closed) {
            return;
        }

        $this->emit('end', [$this]);
        $this->loop->cancelTimer($this->timer);
        $this->removeAllListeners();
        $this->exchange = null;
        $this->closed = true;
    }
public function close ( ) : void { if ( $ this -> closed ) { return ; } $ this -> emit ( 'end' , [ $ this ] ) ; $ this -> loop -> cancelTimer ( $ this -> timer ) ; $ this -> removeAllListeners ( ) ; $ this -> exchange = null ; $ this -> closed = true ; }
Method to call when stopping listening to messages.
Method to call when stopping listening to messages .