AMQPEventListener.php
No OneTemporary
Actions

Size

2 KB

Referenced Files

None

Subscribers

None

AMQPEventListener.php
View Options

	<?php

	namespace Nasqueron\Notifications\Listeners;

	use Nasqueron\Notifications\Events\GitHubPayloadEvent;
	use Nasqueron\Notifications\Analyzers\GitHubPayloadAnalyzer;

	use Illuminate\Queue\InteractsWithQueue;
	use Illuminate\Contracts\Queue\ShouldQueue;

	use Keruald\Broker\AMQPBroker;

	class AMQPEventListener {
	///
	/// GitHub events
	///

	/**
	* Gets routing key, to allow consumers to select the topic they subscribe to.
	*
	* @param GitHubPayloadEvent $event the payload event
	*/
	protected static function getRoutingKey (GitHubPayloadEvent $event) {
	$key = [
	strtolower($event->door),
	self::getGroup($event),
	$event->event
	];
	return implode('.', $key);
	}

	protected static function getAnalyzer (GitHubPayloadEvent $event) {
	return new GitHubPayloadAnalyzer(
	$event->door,
	$event->event,
	$event->payload
	);
	}

	/**
	* Gets the group for a specific payload
	*
	* @return string the group, central part of the routing key
	*/
	protected static function getGroup (GitHubPayloadEvent $event) {
	$analyzer = self::getAnalyzer($event);
	return $analyzer->getGroup();
	}

	/**
	* Handles a GitHub payload event.
	*
	* @param GitHubPayloadEvent $event
	* @return void
	*/
	public function onGitHubPayload(GitHubPayloadEvent $event) {
	$message = json_encode($event->payload);
	$routingKey = static::getRoutingKey($event);

	echo "Event $event->event has been fired to GitHub $event->door door.\nRouting key is $routingKey.";
	$broker = new AMQPBroker();
	$broker
	->connect()
	->setExchangeTarget('github_events')
	->routeTo($routingKey)
	->sendMessage($message);
	}

	///
	/// Events listening
	///

	/**
	* Register the listeners for the subscriber.
	*
	* @param Illuminate\Events\Dispatcher $events
	*/
	public function subscribe ($events) {
	$class = 'Nasqueron\Notifications\Listeners\AMQPEventListener';
	$events->listen(
	'Nasqueron\Notifications\Events\GitHubPayloadEvent',
	"$class@onGitHubPayload"
	);
	}
	}

File Metadata

Mime Type: text/x-php
Expires: Sat, Jan 31, 17:43 (22 h, 17 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3403927
Default Alt Text: AMQPEventListener.php (2 KB)

AMQPEventListener.phpNo OneTemporaryActions

AMQPEventListener.phpView Options

File Metadata

Event Timeline

AMQPEventListener.php
No OneTemporary
Actions

AMQPEventListener.php
View Options