File tree Expand file tree Collapse file tree 2 files changed +3
-5
lines changed
Expand file tree Collapse file tree 2 files changed +3
-5
lines changed Original file line number Diff line number Diff line change 22
33namespace Kiboko \Component \Flow \RabbitMQ ;
44
5- use Bunny \Client ;
65use Kiboko \Contract \Pipeline \StateInterface ;
76
87final class State implements StateInterface
@@ -20,8 +19,6 @@ public function __construct(
2019
2120 public function initialize (): void
2221 {
23- $ this ->manager ->stepState ($ this );
24-
2522 $ this ->acceptMetric = 0 ;
2623 $ this ->rejectMetric = 0 ;
2724 $ this ->errorMetric = 0 ;
Original file line number Diff line number Diff line change @@ -37,9 +37,10 @@ public function __destruct()
3737 }
3838
3939 public function stepState (
40- State $ state
40+ string $ stepCode ,
41+ string $ stepLabel ,
4142 ): State {
42- return $ this ->steps [] = $ state ;
43+ return $ this ->steps [] = new State ( $ this , $ stepCode , $ stepLabel ) ;
4344 }
4445
4546 public function trySend ($ count ): void
You can’t perform that action at this time.
0 commit comments