Code
Explorer
You are a developer and looking for Shopware projects?
Apply Now!
sendOrHandle example
continue
;
}
$offset
= null;
$this
->dispatcher->
dispatch
(
new
ProgressStartedEvent
(
$indexer
->
getName
(
)
,
$indexer
->
getTotal
(
)
)
)
;
while
(
$message
=
$indexer
->
iterate
(
$offset
)
)
{
$message
->
setIndexer
(
$indexer
->
getName
(
)
)
;
$message
->
addSkip
(
...
$skip
)
;
$this
->
sendOrHandle
(
$message
,
$useQueue
)
;
$offset
=
$message
->
getOffset
(
)
;
try
{
$count
= \
is_array
(
$message
->
getData
(
)
)
? \
count
(
$message
->
getData
(
)
)
: 1;
$this
->dispatcher->
dispatch
(
new
ProgressAdvancedEvent
(
$count
)
)
;
}
catch
(
\Exception
)
{
}
}
$this
->dispatcher->
dispatch
(
new
ProgressFinishedEvent
(
$indexer
->
getName
(
)
)
)
;
}