CQBus MediatorClean architecture for Laravel

Decouple your commands, queries, and events with zero configuration. Auto-discovery, attribute routing, and pipelines — out of the box.

Get Started →

View on GitHub

🚀

Zero Configuration

Drop in the package and go. Handlers, notifications, and actions are discovered automatically — no registration arrays, no service providers to edit.

⚡

CQRS & Event Bus

First-class support for Commands, Queries, and Events in one package. Use #[CommandHandler], #[QueryHandler], and #[Notification] to communicate intent clearly.

🛣️

Attribute Routing

Define your route right next to your handler. #[Api], #[Prefix], #[Middleware] — no more hunting through bloated route files.

🔗

Layered Pipelines

Wrap every dispatch in reusable middleware — globally, per type, or per handler. Works seamlessly whether triggered by HTTP, CLI, or a queued job.

🧪

Built for Testing

Mediator::fake() intercepts and records all dispatches so you can assert commands and events without running a single handler.

⚙️

Production Ready

Cache the entire mediator registry with php artisan mediator:cache for zero-reflection dispatch in production — from 157ms boot to 0.06ms.

Stop writing Fat Controllers.
Start writing Actions.

Decouple your business logic, routing, and side effects instantly.

The full CQRS flow — in one Action class

php

// app/Http/Actions/RegisterUserAction.php

#[Api] // ⚡ Applies 'api' middleware group AND 'api/' prefix automatically
class RegisterUserAction
{
    use AsAction;

    public function __construct(private readonly Mediator $mediator) {}

    public static function route(Router $router): void
    {
        $router->post('/register');                    // POST /api/register
    }

    public function handle(RegisterUserRequest $request): JsonResponse
    {
        $user = $this->mediator->send($request);                       // → RegisterUserHandler
        $this->mediator->publish(new UserRegisteredEvent($user->id));  // → N notifications

        return response()->json($user, 201);
    }
}