Skip to content
This repository has been archived by the owner on Jul 20, 2020. It is now read-only.

Commit

Permalink
Merge branch 'release/1.0.2'
Browse files Browse the repository at this point in the history
  • Loading branch information
bramdevries committed Aug 9, 2017
2 parents 9621254 + a607c1f commit 8ff1fb5
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 8 deletions.
6 changes: 6 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,9 @@
### 1.0.2

### Fixed

- Fixed issue where events process managers were still being executed while replaying the event store

### 1.0.1

### Fixed
Expand Down
10 changes: 4 additions & 6 deletions src/EventStore/Services/Replay.php
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,6 @@
namespace Madewithlove\LaravelCqrsEs\EventStore\Services;

use Broadway\Domain\DomainEventStream;
use Broadway\EventHandling\EventBus;
use Broadway\EventHandling\EventBusInterface;
use Broadway\EventStore\CallableEventVisitor;
use Broadway\EventStore\Management\Criteria;
use Broadway\EventStore\Management\EventStoreManagement;
Expand All @@ -14,7 +12,7 @@
class Replay
{
/**
* @var EventBus
* @var ReplayingEventBusInterface
*/
protected $eventBus;

Expand All @@ -34,10 +32,10 @@ class Replay
protected $eventBufferSize = 20;

/**
* @param EventBus $eventBus
* @param ReplayingEventBusInterface $eventBus
* @param EventStoreManagement $eventManager
*/
public function __construct(EventBus $eventBus, EventStoreManagement $eventManager)
public function __construct(ReplayingEventBusInterface $eventBus, EventStoreManagement $eventManager)
{
$this->eventBus = $eventBus;
$this->eventManager = $eventManager;
Expand Down Expand Up @@ -86,4 +84,4 @@ private function addEvent($event)
$this->publishEvents();
}
}
}
}
3 changes: 1 addition & 2 deletions src/Identifier/Identifier.php
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
namespace Madewithlove\LaravelCqrsEs\Identifier;

use Broadway\Serializer\Serializable;
use Broadway\Serializer\SerializableInterface;

interface Identifier extends Serializable
{
Expand All @@ -30,4 +29,4 @@ public function equals(Identifier $identifier);
* @return string
*/
public function toString();
}
}

0 comments on commit 8ff1fb5

Please sign in to comment.