Skip to content

Commit a89d56b

Browse files
committed
- laravel 5.3 update
1 parent 3a3c788 commit a89d56b

File tree

1 file changed

+12
-25
lines changed

1 file changed

+12
-25
lines changed

src/Jobs/AMQPJob.php

Lines changed: 12 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -42,31 +42,7 @@ public function __construct($container, $queue, $channel, $amqpMessage)
4242
$this->amqpMessage = $amqpMessage;
4343
$this->channel = $channel;
4444
}
45-
46-
/**
47-
* Fire the job.
48-
*
49-
* @return void
50-
*/
51-
public function fire()
52-
{
53-
if (is_null($this->payload()))
54-
$this->delete();
55-
else
56-
$this->fire();
57-
}
58-
59-
/**
60-
* Delete the job from the queue.
61-
*
62-
* @return void
63-
*/
64-
public function delete()
65-
{
66-
parent::delete();
67-
$this->channel->basic_ack($this->amqpMessage->delivery_info['delivery_tag']);
68-
}
69-
45+
7046
/**
7147
* Get the raw body string for the job.
7248
*
@@ -108,6 +84,17 @@ public function release($delay = 0)
10884
}
10985
}
11086

87+
/**
88+
* Delete the job from the queue.
89+
*
90+
* @return void
91+
*/
92+
public function delete()
93+
{
94+
parent::delete();
95+
$this->channel->basic_ack($this->amqpMessage->delivery_info['delivery_tag']);
96+
}
97+
11198
/**
11299
* Get the number of times the job has been attempted.
113100
*

0 commit comments

Comments
 (0)