Aimeos\MW\MQueue\Queue\Beanstalk

Complexity

Total Complexity

8

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	2
A	add()	0	8	2
A	del()	0	8	2
A	get()	0	6	2

<?php

namespace Aimeos\MW\MQueue\Queue;


class Beanstalk implements Iface
{
	private $client;
	private $queue;
	private $timeout;


	/**
	 * Initializes the queue object
	 *
	 * @param \Pheanstalk\PheanstalkInterface $client Client object
	 * @param string $queue Message queue name
	 * @throws \Aimeos\MW\MQueue\Exception
	 */
	public function __construct( \Pheanstalk\PheanstalkInterface $client, $queue, $timeout = null )
	{
		try {
			$client->useTube( $queue )->watch( $queue );
		} catch( \Exception $e ) {
			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
		}

		$this->client = $client;
		$this->queue = $queue;
		$this->timeout = $timeout;
	}


	/**
	 * Adds a new message to the message queue
	 *
	 * @param string $msg Message, e.g. JSON encoded data
	 */
	public function add( $msg )
	{
		try {
			$this->client->put( $msg );
		} catch( \Exception $e ) {
			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
		}
	}


	/**
	 * Removes the message from the queue
	 *
	 * @param \Aimeos\MW\MQueue\Message\Iface $msg Message object
	 */
	public function del( \Aimeos\MW\MQueue\Message\Iface $msg )
	{
		try {
			$this->client->delete( $msg->getObject() );
		} catch( \Exception $e ) {
			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
		}
	}


	/**
	 * Returns the next message from the queue
	 *
	 * @return \Aimeos\MW\MQueue\Message\Iface|null Message object or null if none is available
	 */
	public function get()
	{
		if( ( $job = $this->client->reserve( $this->timeout ) ) !== false ) {
			return new \Aimeos\MW\MQueue\Message\Beanstalk( $job );
		}
	}
}