'deliveryStatus' => WebhookEventLogDefinition::STATUS_QUEUED,
'webhookName' => 'hook1',
'eventName' => 'order',
'appVersion' => '0.0.1',
'url' => 'https://test.com',
'serializedWebhookMessage' =>
serialize($webhookEventMessage),
]],
$this->context
);
$event =
new WorkerMessageFailedEvent( new Envelope($webhookEventMessage),
'async',
new ClientException('test',
new Request('GET', 'https://test.com'
),
new Response(500
)) );
$this->
getContainer()->
get(RetryWebhookMessageFailedSubscriber::
class) ->
failed($event);
$webhookEventLog =
$webhookEventLogRepository->
search(new Criteria([$webhookEventId]),
$this->context
)->
first();
static::
assertEquals($webhookEventLog->
getDeliveryStatus(), WebhookEventLogDefinition::STATUS_FAILED
);
}}