Skip to content

Commit a1c241a

Browse files
authored
Merge pull request #22 from MacPaw/fix/reset_resolver_values_per_each_message_2
fix: reset resolver values per each message
2 parents 602c311 + fb65d18 commit a1c241a

1 file changed

Lines changed: 9 additions & 9 deletions

File tree

src/Messenger/Middleware/BaggageSchemaMiddleware.php

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -29,19 +29,19 @@ public function handle(Envelope $envelope, StackInterface $stack): Envelope
2929
->setBaggage($this->baggageCodec->decode($stamp->baggage));
3030

3131
$result = $stack->next()->handle($envelope, $stack);
32+
} else {
33+
$schema = $this->baggageSchemaResolver->getSchema();
34+
$baggage = $this->baggageCodec->encode($this->baggageSchemaResolver->getBaggage() ?? []);
3235

33-
$this->baggageSchemaResolver->reset();
36+
if ($schema !== null && $schema !== '') {
37+
$envelope = $envelope->with(new BaggageSchemaStamp($schema, $baggage));
38+
}
3439

35-
return $result;
40+
$result = $stack->next()->handle($envelope, $stack);
3641
}
3742

38-
$schema = $this->baggageSchemaResolver->getSchema();
39-
$baggage = $this->baggageCodec->encode($this->baggageSchemaResolver->getBaggage() ?? []);
40-
41-
if ($schema !== null && $schema !== '') {
42-
$envelope = $envelope->with(new BaggageSchemaStamp($schema, $baggage));
43-
}
43+
$this->baggageSchemaResolver->reset();
4444

45-
return $stack->next()->handle($envelope, $stack);
45+
return $result;
4646
}
4747
}

0 commit comments

Comments
 (0)