@@ -98,16 +98,17 @@ public function setSendErrorHandler(callable $handler) {
9898 protected function createQueueEntry (\Nette \Mail \Message $ message , $ custom = []) {
9999 /** @var Entity\AbstractMailQueueEntry $entry */
100100 $ entry = new $ this ->queueEntryClass ;
101- $ entry ->createdAt = new \DateTime ;
102- $ entry ->from = array_keys ($ message ->getFrom ())[0 ];
103- $ entry ->subject = $ message ->getSubject ();
104- $ entry ->message = $ message ;
101+ $ entry ->setCreatedAt ( new \DateTime ) ;
102+ $ entry ->setFrom ( array_keys ($ message ->getFrom ())[0 ]) ;
103+ $ entry ->setSubject ( $ message ->getSubject () );
104+ $ entry ->setMessage ( $ message) ;
105105
106106 if (is_callable ($ custom )) {
107107 $ custom ($ entry );
108108 } else {
109109 foreach ($ custom as $ field => $ value ) {
110- $ entry ->$ field = $ value ;
110+ $ setter = 'set ' . ucfirst ($ field );
111+ $ entry ->$ setter ($ value );
111112 }
112113 }
113114
@@ -152,7 +153,7 @@ public function enqueue(\Nette\Mail\Message $message, $custom = []) {
152153
153154 protected function send (Entity \AbstractMailQueueEntry $ entry ) {
154155 if ($ this ->mailer ) {
155- $ this ->mailer ->send ($ entry ->message );
156+ $ this ->mailer ->send ($ entry ->getMessage () );
156157 } else {
157158 $ this ->messenger ->send ($ entry );
158159 }
@@ -173,7 +174,7 @@ public function process(\ADT\BackgroundQueue\Entity\QueueEntity $entity) {
173174
174175 try {
175176 $ this ->send ($ entry );
176- $ entry ->sentAt = new \DateTime ;
177+ $ entry ->setSentAt ( new \DateTime ) ;
177178 } catch (\Exception $ e ) {
178179 $ msg = $ e ->getMessage ();
179180
0 commit comments