Skip to content

Commit

Permalink
🎨 Styling
Browse files Browse the repository at this point in the history
  • Loading branch information
petermein committed Nov 10, 2018
1 parent d7d8365 commit acdf6b9
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 5 deletions.
4 changes: 1 addition & 3 deletions src/Exceptions/QueueKafkaException.php
Original file line number Diff line number Diff line change
@@ -1,10 +1,8 @@
<?php


namespace Rapide\LaravelQueueKafka\Exceptions;


class QueueKafkaException extends \RuntimeException
{

//
}
8 changes: 6 additions & 2 deletions src/Queue/KafkaQueue.php
Original file line number Diff line number Diff line change
Expand Up @@ -90,8 +90,9 @@ public function push($job, $data = '', $queue = null)
* @param string $queue
* @param array $options
*
* @return mixed
* @throws QueueKafkaException
*
* @return mixed
*/
public function pushRaw($payload, $queue = null, array $options = [])
{
Expand All @@ -116,6 +117,8 @@ public function pushRaw($payload, $queue = null, array $options = [])
* @param mixed $data
* @param string $queue
*
* @throws QueueKafkaException
*
* @return mixed
*/
public function later($delay, $job, $data = '', $queue = null)
Expand All @@ -129,8 +132,9 @@ public function later($delay, $job, $data = '', $queue = null)
*
* @param string|null $queue
*
* @return \Illuminate\Queue\Jobs\Job|null
* @throws QueueKafkaException
*
* @return \Illuminate\Queue\Jobs\Job|null
*/
public function pop($queue = null)
{
Expand Down

0 comments on commit acdf6b9

Please sign in to comment.