33 * Copyright © Magento, Inc. All rights reserved.
44 * See COPYING.txt for license details.
55 */
6+
7+ declare (strict_types=1 );
8+
69namespace Magento \Newsletter \Model ;
710
11+ use Magento \Newsletter \Model \ResourceModel \Queue \Collection ;
12+ use Magento \Newsletter \Model \ResourceModel \Queue \CollectionFactory ;
13+
814/**
915 * Newsletter module observer
1016 *
1117 * @SuppressWarnings(PHPMD.LongVariable)
1218 */
1319class Observer
1420{
21+ /**
22+ * Number of queue
23+ */
24+ private const COUNT_OF_QUEUE = 3 ;
25+
26+ /**
27+ * Number of subscriptions
28+ */
29+ private const COUNT_OF_SUBSCRIPTIONS = 20 ;
30+
31+ /**
32+ * First page in collection
33+ */
34+ private const FIRST_PAGE = 1 ;
35+
1536 /**
1637 * Queue collection factory
1738 *
18- * @var \Magento\Newsletter\Model\ResourceModel\Queue\ CollectionFactory
39+ * @var CollectionFactory
1940 */
2041 protected $ _queueCollectionFactory ;
2142
2243 /**
2344 * Construct
2445 *
25- * @param \Magento\Newsletter\Model\ResourceModel\Queue\ CollectionFactory $queueCollectionFactory
46+ * @param CollectionFactory $queueCollectionFactory
2647 */
2748 public function __construct (
28- \ Magento \ Newsletter \ Model \ ResourceModel \ Queue \ CollectionFactory $ queueCollectionFactory
49+ CollectionFactory $ queueCollectionFactory
2950 ) {
3051 $ this ->_queueCollectionFactory = $ queueCollectionFactory ;
3152 }
@@ -37,13 +58,11 @@ public function __construct(
3758 */
3859 public function scheduledSend ()
3960 {
40- $ countOfQueue = 3 ;
41- $ countOfSubscriptions = 20 ;
42-
43- /** @var \Magento\Newsletter\Model\ResourceModel\Queue\Collection $collection */
61+ /** @var Collection $collection */
4462 $ collection = $ this ->_queueCollectionFactory ->create ();
45- $ collection ->setPageSize ($ countOfQueue )->setCurPage (1 )->addOnlyForSendingFilter ()->load ();
63+ $ collection ->setPageSize (self ::COUNT_OF_QUEUE )
64+ ->setCurPage (self ::FIRST_PAGE )->addOnlyForSendingFilter ()->load ();
4665
47- $ collection ->walk ('sendPerSubscriber ' , [$ countOfSubscriptions ]);
66+ $ collection ->walk ('sendPerSubscriber ' , [self :: COUNT_OF_SUBSCRIPTIONS ]);
4867 }
4968}
0 commit comments