Post.php

<?php

class PostAggregateRoot
{
    public function publishPost(DateTime $when) {
        $this->recordThat(new PostPublishScheduled($when));

        if ($when < now()) {
            $this->recordThat(new PostPublished());
        }

        return $this;
    }

    public function publishPostNow() {
        $this->recordThat(new PostPublished());

        return $this;
    }
}

class PublishPostsConsole
{
    public function run() {
        $posts = Post::toBePublished(); // query in the model

        foreach ($posts as $post) {
            PostAggregateRoot::retrieve($post->id)
                ->publishPostNow()
                ->persist();
        }
    }
}