File tree Expand file tree Collapse file tree 2 files changed +8
-0
lines changed
Expand file tree Collapse file tree 2 files changed +8
-0
lines changed Original file line number Diff line number Diff line change 33namespace Robertbaelde \PersistingMessageBus ;
44
55use EventSauce \EventSourcing \ReplayingMessages \TriggerBeforeReplay ;
6+ use Robertbaelde \PersistingMessageBus \MessageRepository \SorryConsumerIsLocked ;
67
78class MessageConsumer
89{
@@ -12,6 +13,9 @@ public function __construct(
1213 protected \EventSauce \EventSourcing \MessageConsumer $ messageConsumer ,
1314 ){}
1415
16+ /**
17+ * @throws SorryConsumerIsLocked
18+ */
1519 public function handleNewMessages (): int
1620 {
1721 $ cursor = $ this ->messageConsumerState ->getCursor ();
Original file line number Diff line number Diff line change 33namespace Robertbaelde \PersistingMessageBus ;
44
55use Robertbaelde \PersistingMessageBus \MessageRepository \Cursor ;
6+ use Robertbaelde \PersistingMessageBus \MessageRepository \SorryConsumerIsLocked ;
67
78interface MessageConsumerState
89{
10+ /**
11+ * @throws SorryConsumerIsLocked
12+ */
913 public function getCursor (): Cursor ;
1014
1115 public function storeNewCursor (Cursor $ cursor ): void ;
You can’t perform that action at this time.
0 commit comments