octante / NatsBundle

     *

     * @return void

     */

    public function request($subject, $payload, $callback, $wait = 1)

    {

        $startTime = microtime(true);

        $this->connection->request($subject, $payload, $callback, $wait);

        $duration = (microtime(true) - $startTime) * 1000;

        $this->logger->logCommand('REQUEST: ', $duration, $this->connection, false);

    }

    /**

     * Publish publishes the data argument to the given subject.

     *

     * @return void

     */

    public function publish($subject, $payload)

    {

        $startTime = microtime(true);

        $this->connection->publish($subject, $payload);

        $duration = (microtime(true) - $startTime) * 1000;

        $this->logger->logCommand('PUBLISH: ' . $subject, $duration, $this->connection, false);

    }

    /**

     * Subscribes to an specific event given a subject.

     *

     * @return string

     */

    public function subscribe($subject, \Closure $callback)

    {

        $startTime = microtime(true);

        $result = $this->connection->subscribe($subject, $callback);

        $duration = (microtime(true) - $startTime) * 1000;

        $this->logger->logCommand('SUBSCRIBE: ' . $subject, $duration, $this->connection, false);

        return $result;

    }

    /**

     * Unsubscribe from a event given a subject.

     *

     * @return void

     */

    public function unsubscribe($sid)

    {

        $startTime = microtime(true);

        $this->connection->unsubscribe($sid);

        $duration = (microtime(true) - $startTime) * 1000;

        $this->logger->logCommand('UNSUBSCRIBE: ' . $sid, $duration, $this->connection, false);

    }

    /**

     * Waits for messages.