shippinno /
job
| @@ 51-63 (lines=13) @@ | ||
| 48 | * @param EnqueuedStoredJobTrackerStore $enqueuedStoredJobTrackerStore |
|
| 49 | * @param JobFlightManager|null $jobFlightManager |
|
| 50 | */ |
|
| 51 | public function __construct( |
|
| 52 | PsrContext $context, |
|
| 53 | JobStore $jobStore, |
|
| 54 | StoredJobSerializer $storedJobSerializer, |
|
| 55 | EnqueuedStoredJobTrackerStore $enqueuedStoredJobTrackerStore, |
|
| 56 | JobFlightManager $jobFlightManager = null |
|
| 57 | ) { |
|
| 58 | $this->context = $context; |
|
| 59 | $this->jobStore = $jobStore; |
|
| 60 | $this->storedJobSerializer = $storedJobSerializer; |
|
| 61 | $this->enqueuedStoredJobTrackerStore = $enqueuedStoredJobTrackerStore; |
|
| 62 | $this->jobFlightManager = $jobFlightManager ?: new NullJobFlightManager; |
|
| 63 | } |
|
| 64 | ||
| 65 | /** |
|
| 66 | * @param string $topicName |
|
| @@ 40-50 (lines=11) @@ | ||
| 37 | * @param StoredJobSerializer $storedJobSerializer |
|
| 38 | * @param JobFlightManager|null $jobFlightManager |
|
| 39 | */ |
|
| 40 | public function __construct( |
|
| 41 | PsrContext $context, |
|
| 42 | AbandonedJobMessageStore $abandonedJobMessageStore, |
|
| 43 | StoredJobSerializer $storedJobSerializer, |
|
| 44 | JobFlightManager $jobFlightManager = null |
|
| 45 | ) { |
|
| 46 | $this->context = $context; |
|
| 47 | $this->abandonedJobMessageStore = $abandonedJobMessageStore; |
|
| 48 | $this->storedJobSerializer = $storedJobSerializer; |
|
| 49 | $this->jobFlightManager = $jobFlightManager ?: new NullJobFlightManager; |
|
| 50 | } |
|
| 51 | ||
| 52 | /** |
|
| 53 | * @param int $abandonedJobMessageId |
|
| @@ 44-54 (lines=11) @@ | ||
| 41 | * @param StoredJobSerializer $storedJobSerializer |
|
| 42 | * @param JobFlightManager|null $jobFlightManager |
|
| 43 | */ |
|
| 44 | public function __construct( |
|
| 45 | PsrContext $context, |
|
| 46 | JobStore $jobStore, |
|
| 47 | StoredJobSerializer $storedJobSerializer, |
|
| 48 | JobFlightManager $jobFlightManager = null |
|
| 49 | ) { |
|
| 50 | $this->context = $context; |
|
| 51 | $this->jobStore = $jobStore; |
|
| 52 | $this->storedJobSerializer = $storedJobSerializer; |
|
| 53 | $this->jobFlightManager = $jobFlightManager ?: new NullJobFlightManager; |
|
| 54 | } |
|
| 55 | ||
| 56 | /** |
|
| 57 | * @param string $topicName |
|
