Simplify getSinglePayloadByClass, remove wrong check
[MAILPOET-5720]
This commit is contained in:
@@ -113,16 +113,13 @@ class StepRunArgs {
|
|||||||
public function getSinglePayloadByClass(string $class): Payload {
|
public function getSinglePayloadByClass(string $class): Payload {
|
||||||
$payloads = [];
|
$payloads = [];
|
||||||
foreach ($this->subjectEntries as $entries) {
|
foreach ($this->subjectEntries as $entries) {
|
||||||
if (count($entries) > 1) {
|
foreach ($entries as $entry) {
|
||||||
throw Exceptions::multiplePayloadsFound($class, $this->automationRun->getId());
|
|
||||||
}
|
|
||||||
|
|
||||||
$entry = $entries[0];
|
|
||||||
$payload = $entry->getPayload();
|
$payload = $entry->getPayload();
|
||||||
if (get_class($payload) === $class) {
|
if (get_class($payload) === $class) {
|
||||||
$payloads[] = $payload;
|
$payloads[] = $payload;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (count($payloads) === 0) {
|
if (count($payloads) === 0) {
|
||||||
throw Exceptions::payloadNotFound($class, $this->automationRun->getId());
|
throw Exceptions::payloadNotFound($class, $this->automationRun->getId());
|
||||||
|
Reference in New Issue
Block a user