Merge pull request #51 from sugrob/customizeAMQPException

Customize amqp exception

Author: sugrob

doc/ChangeLog

@@ -1,3 +1,8 @@
+2011-11-14      Dmitry V. Snezhinskiy
+	
+	* main/Utils/AMQP/Pecl/AMQPPeclChannel.class.php :
+	customize AMQPPeclChannel Exception. Author Evgenia T. Tekalin
+
 2011-11-14	Evgeny V. Kokovikhin
 
 	* core/Cache/PeclMemcached.class.php, test/core/MemcachedTest.class.php :

main/Utils/AMQP/Pecl/AMQPPeclChannel.class.php

@@ -317,7 +317,7 @@ public function exchangeDelete(
 			$this->unsetExchange($name);
 
 			return $this;
-		}		
+		}
 
 		/**
 		 * @throws AMQPServerException|AMQPServerConnectionException
@@ -499,7 +499,12 @@ public function getNextDelivery()
 				$this->consumer->getConsumerTag()
 				!= $incoming->getConsumerTag()
 			) {
-				throw new WrongStateException('Consumer change tag');
+				throw new WrongStateException(
+					"Consumer change tag consumerTag="
+					."{$this->consumer->getConsumerTag()}, "
+					."message.consumerTag={$incoming->getConsumerTag()}, "
+					."message.body={$incoming->getBody()}"
+				);
 			}
 
 			$this->consumer->handleDelivery($incoming);