Page MenuHomeDevCentral
Files F11726207

No OneTemporary
Actions

View Options

diff --git a/app/Jobs/SendMessageToBroker.php b/app/Jobs/SendMessageToBroker.php
index efc61f1..1452c05 100644
--- a/app/Jobs/SendMessageToBroker.php
+++ b/app/Jobs/SendMessageToBroker.php
@@ -1,91 +1,91 @@
<?php
namespace Nasqueron\Notifications\Jobs;
use Illuminate\Contracts\Bus\SelfHandling;
use Nasqueron\Notifications\Actions\AMQPAction;
use Nasqueron\Notifications\Events\ReportEvent;
use Nasqueron\Notifications\Jobs\Job;
use Broker;
use Event;
class SendMessageToBroker extends Job implements SelfHandling {
///
/// Private members
///
/**
* The routing key, for topic exchange
*
* @var string
*/
private $routingKey = '';
/**
* The message to send
*
* @var string
*/
private $message = '';
/**
* The target exchange
*
* @var string
*/
private $target = 'github_events';
///
/// Constructor
///
/**
* Create a new job instance.
*
- * @param $routingKey the routing key, for topic exchange
- * @param $message the message to send
+ * @param string $routingKey the routing key, for topic exchange
+ * @param string $message the message to send
*
* @return void
*/
public function __construct ($routingKey, $message) {
$this->routingKey = $routingKey;
$this->message = $message;
}
///
/// Task
///
/**
* Executes the job.
*
* @return void
*/
public function handle() {
$this->sendMessage();
$this->report();
}
/**
* Sends the message to the broker
*/
protected function sendMessage () {
Broker::setExchangeTarget($this->target)
->routeTo($this->routingKey)
->sendMessage($this->message);
}
/**
* Prepares a report and fires a report event
*/
protected function report () {
$actionToReport = new AMQPAction(
"publish",
$this->target,
$this->routingKey
);
Event::fire(new ReportEvent($actionToReport));
}
}

File Metadata

Mime Type
text/x-diff
Expires
Fri, Sep 19, 01:18 (1 d, 2 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2990019
Default Alt Text
(2 KB)

Event Timeline

Nasqueron DevCentral · If it had been much bigger the moon would have had a core of ice. · Powered by Phabricator