Skip to content

Commit 0a02bfa

Browse files
authored
Merge pull request #10 from AppsDevTeam/fix-callback-process-parameters
Fix callback process parameters
2 parents 52da2ff + 17e1e8c commit 0a02bfa

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

src/Service/QueueService.php

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -141,14 +141,12 @@ protected function send(Entity\AbstractMailQueueEntry $entry) {
141141

142142

143143
/**
144-
* @param \ADT\BackgroundQueue\Entity\QueueEntity $entity
144+
* @param int $entryId
145145
* @return bool
146146
*
147147
* new_rabbit
148148
*/
149-
public function process(\ADT\BackgroundQueue\Entity\QueueEntity $entity) {
150-
$parameters = $entity->getParameters();
151-
$entryId = $parameters[self::PARAMETER_NAME_MAIL_QUEUE_ENTRY_ID];
149+
public function process(int $entryId) {
152150
$entry = $this->em->find($this->queueEntryClass, $entryId);
153151

154152

0 commit comments

Comments
 (0)