Aimeos\MW\MQueue\Queue\AMQP

Complexity

Total Complexity

11

Size/Duplication

Total Lines	97
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	2
Bugs	0	Features	2

5 Methods

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

<?php

namespace Aimeos\MW\MQueue\Queue;


class AMQP implements Iface
{
	private $channel;
	private $queue;


	/**
	 * Initializes the message queue class
	 *
	 * @param \PhpAmqpLib\Channel\AMQPChannel $channel AMQP channel
	 * @param string $queue Message queue name
	 * @throws \Aimeos\MW\MQueue\Exception
	 */
	public function __construct( \PhpAmqpLib\Channel\AMQPChannel $channel, $queue )
	{
		try
		{
			$channel->queue_declare( $queue, false, true, false, false );
			$channel->basic_qos( null, 1, null );
		}
		catch( \Exception $e )
		{
			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
		}

		$this->channel = $channel;
		$this->queue = $queue;
	}


	/**
	 * Closes the channel on cleanup
	 */
	public function __destruct()
	{
		try {
			$this->channel->close();
		} catch( \Exception $e ) { ; }

Consider adding a comment why this CATCH block is empty.

	}


	/**
	 * Adds a new message to the message queue
	 *
	 * @param string $msg Message, e.g. JSON encoded data
	 * @throws \Aimeos\MW\MQueue\Exception
	 */
	public function add( $msg )
	{
		try
		{
			$message = new \PhpAmqpLib\Message\AMQPMessage( $msg, array( 'delivery_mode' => 2 ) );
			$this->channel->basic_publish( $message, '', $this->queue );
		}
		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
	 * @throws \Aimeos\MW\MQueue\Exception
	 */
	public function del( \Aimeos\MW\MQueue\Message\Iface $msg )
	{
		try {
			$this->channel->basic_ack( $msg->getObject()->delivery_info['delivery_tag'] );
		} 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
	 * @throws \Aimeos\MW\MQueue\Exception
	 */
	public function get()
	{
		try
		{
			if( ( $msg = $this->channel->basic_get( $this->queue ) ) !== null ) {
				return new \Aimeos\MW\MQueue\Message\AMQP( $msg );
			}
		}
		catch( \Exception $e )
		{
			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
		}
	}
}