first commit

Author: vyuldashev

.gitignore

@@ -0,0 +1,2 @@
+/vendor
+composer.lock

README.md

@@ -1,2 +1,52 @@
-laravel-queue-rabbitmq
+RabbitMQ driver for Laravel
 ======================
+
+####Installation
+
+Require this package in your composer.json and run composer update:
+
+	fintech-fab/laravel-queue-rabbitmq
+    
+or run:
+
+	composer require fintech-fab/laravel-queue-rabbitmq:*
+
+After composer update is finished you need to add ServiceProvider to your `providers` array in app.php:
+				
+   
+	'FintechFab\LaravelQueueRabbitMQ\LaravelQueueRabbitMQServiceProvider',
+
+
+now you are able to configure your connections in queue.php:
+
+    return array(
+    
+        'default'     => 'rabbitmq',
+    
+        'connections' => array(
+    
+            'rabbitmq' => array(
+                'driver'        => 'rabbitmq',
+    
+                'host'          => '',
+                'port'          => '',
+    
+                'vhost'         => '',
+                'login'         => '',
+                'password'      => '',
+    
+                'queue'         => '', // name of the default queue
+                'exchange_name' => '', // name of the exchange
+            ),
+    
+        ),
+    
+    );
+
+You can also find these examples in src/examples folder. 
+
+####PHPUnit
+Unit tests will be provided soon.
+
+####Contribution
+You can contribute to this package by discovering buys and opening issues. Enjoy!

composer.json

@@ -0,0 +1,26 @@
+{
+	"name": "fintech-fab/laravel-queue-rabbitmq",
+	"description": "RabbitMQ driver for Laravel Queue",
+	"license": "Apache-2.0",
+	"authors": [
+		{
+			"name": "FINTECH_FAB",
+			"email": "dev@fintech-fab.ru"
+		}
+	],
+	"require": {
+		"php": ">=5.3.0",
+		"illuminate/support": "4.0.x",
+		"illuminate/queue": "4.0.*@dev"
+	},
+	"suggest": {
+		"ext-amqp": "PECL extension for the AMQP protocol - this is preferred",
+		"videlalvaro/php-amqplib": "Pure PHP implementation of the AMQP protocol. If you are not able to install PECL extension - feel free to use this one"
+	},
+	"autoload": {
+		"psr-0": {
+			"FintechFab\\LaravelQueueRabbitMQ": "src/"
+		}
+	},
+	"minimum-stability": "dev"
+}

phpunit.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit backupGlobals="false"
+         backupStaticAttributes="false"
+         bootstrap="vendor/autoload.php"
+         colors="true"
+         convertErrorsToExceptions="true"
+         convertNoticesToExceptions="true"
+         convertWarningsToExceptions="true"
+         processIsolation="false"
+         stopOnFailure="false"
+         syntaxCheck="false"
+		>
+	<testsuites>
+		<testsuite name="Package Test Suite">
+			<directory suffix=".php">./tests/</directory>
+		</testsuite>
+	</testsuites>
+</phpunit>

src/FintechFab/LaravelQueueRabbitMQ/LaravelQueueRabbitMQServiceProvider.php

@@ -0,0 +1,25 @@
+<?php namespace FintechFab\LaravelQueueRabbitMQ;
+
+use FintechFab\LaravelQueueRabbitMQ\Queue\Connectors\RabbitMQConnector;
+use Illuminate\Support\ServiceProvider;
+use Queue;
+
+class LaravelQueueRabbitMQServiceProvider extends ServiceProvider
+{
+
+	/**
+	 * Register the service provider.
+	 *
+	 * @return void
+	 */
+	public function register()
+	{
+		$this->app->booted(function () {
+
+			Queue::extend('rabbitmq', function () {
+				return new RabbitMQConnector;
+			});
+
+		});
+	}
+}

src/FintechFab/LaravelQueueRabbitMQ/Queue/Connectors/RabbitMQConnector.php

@@ -0,0 +1,30 @@
+<?php namespace FintechFab\LaravelQueueRabbitMQ\Queue\Connectors;
+
+use AMQPConnection;
+use FintechFab\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
+use Illuminate\Queue\Connectors\ConnectorInterface;
+
+class RabbitMQConnector implements ConnectorInterface
+{
+
+	/**
+	 * Establish a queue connection.
+	 *
+	 * @param  array $config
+	 *
+	 * @return \Illuminate\Queue\QueueInterface
+	 */
+	public function connect(array $config)
+	{
+
+		// create connection with AMQP
+		$connection = new AMQPConnection($config);
+		$connection->connect();
+
+		return new RabbitMQQueue(
+			$connection,
+			$config['queue'],
+			$config['exchange_name']
+		);
+	}
+}

src/FintechFab/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php

@@ -0,0 +1,86 @@
+<?php namespace FintechFab\LaravelQueueRabbitMQ\Queue\Jobs;
+
+use AMQPEnvelope;
+use AMQPQueue;
+use Illuminate\Queue\Jobs\Job;
+use Queue;
+
+class RabbitMQJob extends Job
+{
+
+	protected $queue;
+	protected $envelope;
+
+	public function __construct($container, AMQPQueue $queue, AMQPEnvelope $envelope)
+	{
+		$this->container = $container;
+		$this->queue = $queue;
+		$this->envelope = $envelope;
+	}
+
+	/**
+	 * Fire the job.
+	 *
+	 * @return void
+	 */
+	public function fire()
+	{
+		$this->resolveAndFire(json_decode($this->envelope->getBody(), true));
+	}
+
+	/**
+	 * Delete the job from the queue.
+	 *
+	 * @return void
+	 */
+	public function delete()
+	{
+		$this->queue->ack($this->envelope->getDeliveryTag());
+	}
+
+	/**
+	 * Release the job back into the queue.
+	 *
+	 * @param  int $delay
+	 *
+	 * @return void
+	 */
+	public function release($delay = 0)
+	{
+		$this->delete();
+
+		$body = $this->envelope->getBody();
+		$body = json_decode($body, true);
+
+		$attempts = $this->attempts();
+
+		// write attempts to body
+		$body['data']['attempts'] = $attempts + 1;
+
+		// push back to a queue
+		Queue::push($body['job'], $body['data']);
+	}
+
+	/**
+	 * Get the number of times the job has been attempted.
+	 *
+	 * @return int
+	 */
+	public function attempts()
+	{
+		$body = json_decode($this->envelope->getBody(), true);
+
+		return isset($body['data']['attempts']) ? $body['data']['attempts'] : 0;
+	}
+
+	/**
+	 * Get the job identifier.
+	 *
+	 * @return string
+	 */
+	public function getJobId()
+	{
+		return $this->envelope->getMessageId();
+	}
+
+}