This package is abandoned and no longer maintained. The author suggests using the broadway/event-store-mongodb package instead.

A mongodb driver for Broadway

0.2.0 2016-04-22 20:23 UTC

This package is auto-updated.

Last update: 2019-11-15 15:26:02 UTC


Build Status Latest Stable Version Total Downloads Scrutinizer Quality Score Code Coverage

A MongoDB driver for Broadway based on mongodb/mongodb.



This package has the same requirements as mongodb/mongodb.

$ pecl install mongodb
$ echo "" >> `php --ini | grep "Loaded Configuration" | sed -e "s|.*:\s*||"`

Via Composer

$ composer require madewithlove/broadway-mongodb



This package ships with a factory to build a MongoDB\Client.

Using default values

$factory = new MongoDBClientFactory();
$client = $factory->create(['database' => 'foobar']);

Creating a client for a specific host and port

$factory = new MongoDBClientFactory();
$client = $factory->create([
     'database' => 'foobar',
     'host' => 'my_host',
     'port' => 3000,

// Or alternatively

$client = $factory->create([
     'database' => 'foobar',
     'host' => 'my_host:3000',

Creating a client for multiple hosts

The hosts option can also be an array for multiple hosts

$factory = new MongoDBClientFactory();
$client = $factory->create([
     'database' => 'foobar',
     'host' => ['my_host_1', 'my_host_2'],

Creating a client for with username and password

If you have to authenticate to your MongoDB database you can pass the username and password

$factory = new MongoDBClientFactory();
$client = $factory->create([
     'database' => 'foobar',
     'username' => 'foo',
     'password' => 'bar',

Creating a client using a dsn string

Alternatively you can pass a dsn string and it will be used to connect

$factory = new MongoDBClientFactory();
$client = $factory->create([
     'dsn' => 'mongodb://foo:200/foo',


This package ships with a basic MongoDBRepository class you can either use directly or extend to build your own repositories.

The easiest way to create a repository for your model is by using the ReadModel\Factory:

$mongDBClientFactory = new MongoDBClientFactory();
$client = $factory->create(['database' => 'testing']);

$factory = new ReadModel\Factory(
   new SimpleInterfaceSerializer(),

// 'my_projection' is the collection that will be used.
$repository = $factory->create('my_projector');

// If you have a custom read model repository you can use the factory to create your own instances:
$repository = $factory->create('my_projector', MyReadModelRepository::class);


$ composer test


The MIT License (MIT). Please see License File for more information.