kakserpom / phpdaemon

     * @throws \InvalidArgumentException

     * @throws \PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPProtocolException

     */

    public function purgeQueue($name, array $options = [], callable $callback = null)

    {

        $noWait = array_key_exists('noWait', $options) ? (bool)$options['noWait'] : null;

        $outputFrame = Queue\QueuePurgeFrame::create($name, $noWait);

        $outputFrame->frameChannelId = $this->id;

        $this->connection->command($outputFrame);

        if (is_callable($callback)) {

            $this->on(self::EVENT_ON_CHANNEL_PURGE_QUEUE_CALLBACK, $callback);

        }

    }

    /**

     * Bind queue to exchange

     * @throws \InvalidArgumentException

     * @throws \PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPProtocolException

     */

    public function get($queueName, array $options = [], callable $callback = null)

    {

        $noAck = array_key_exists('noAck', $options) ? $options['noAck'] : null;

        $outputFrame = Basic\BasicGetFrame::create(

            $queueName,

            $noAck

        );

        $outputFrame->frameChannelId = $this->id;

        $this->connection->command($outputFrame);

        if (is_callable($callback)) {

            $this->on(self::EVENT_DISPATCH_MESSAGE, $callback);

        }

    }

    /**

     * Ack message by delivery tag