Code
Explorer
You are a developer and looking for Shopware projects?
Apply Now!
printPendingMessagesMessage example
$failureTransportName
=
$input
->
getOption
(
'transport'
)
;
if
(
self::DEFAULT_TRANSPORT_OPTION ===
$failureTransportName
)
{
$this
->
printWarningAvailableFailureTransports
(
$io
,
$this
->
getGlobalFailureReceiverName
(
)
)
;
}
if
(
'' ===
$failureTransportName
|| null ===
$failureTransportName
)
{
$failureTransportName
=
$this
->
interactiveChooseFailureTransport
(
$io
)
;
}
$failureTransportName
= self::DEFAULT_TRANSPORT_OPTION ===
$failureTransportName
?
$this
->
getGlobalFailureReceiverName
(
)
:
$failureTransportName
;
$receiver
=
$this
->
getReceiver
(
$failureTransportName
)
;
$this
->
printPendingMessagesMessage
(
$receiver
,
$io
)
;
$io
->
writeln
(
sprintf
(
'To retry all the messages, run <comment>messenger:consume %s</comment>',
$failureTransportName
)
)
;
$shouldForce
=
$input
->
getOption
(
'force'
)
;
$ids
=
$input
->
getArgument
(
'id'
)
;
if
(
0 === \
count
(
$ids
)
)
{
if
(
!
$input
->
isInteractive
(
)
)
{
throw
new
RuntimeException
(
'Message id must be passed when in non-interactive mode.'
)
;
}
$this
->
runInteractive
(
$failureTransportName
,
$io
,
$shouldForce
)
;
$failureTransportName
=
$input
->
getOption
(
'transport'
)
;
if
(
self::DEFAULT_TRANSPORT_OPTION ===
$failureTransportName
)
{
$this
->
printWarningAvailableFailureTransports
(
$io
,
$this
->
getGlobalFailureReceiverName
(
)
)
;
}
if
(
'' ===
$failureTransportName
|| null ===
$failureTransportName
)
{
$failureTransportName
=
$this
->
interactiveChooseFailureTransport
(
$io
)
;
}
$failureTransportName
= self::DEFAULT_TRANSPORT_OPTION ===
$failureTransportName
?
$this
->
getGlobalFailureReceiverName
(
)
:
$failureTransportName
;
$receiver
=
$this
->
getReceiver
(
$failureTransportName
)
;
$this
->
printPendingMessagesMessage
(
$receiver
,
$io
)
;
if
(
!
$receiver
instanceof ListableReceiverInterface
)
{
throw
new
RuntimeException
(
sprintf
(
'The "%s" receiver does not support listing or showing specific messages.',
$failureTransportName
)
)
;
}
if
(
$input
->
getOption
(
'stats'
)
)
{
$this
->
listMessagesPerClass
(
$failureTransportName
,
$io
,
$input
->
getOption
(
'max'
)
)
;
}
elseif
(
null ===
$id
=
$input
->
getArgument
(
'id'
)
)
{
$this
->
listMessages
(
$failureTransportName
,
$io
,
$input
->
getOption
(
'max'
)
,
$input
->
getOption
(
'class-filter'
)
)
;
}
else
{
$this
->
showMessage
(
$failureTransportName
,
$id
,
$io
)
;
}