Fix #342 Define callback method

Pavel Batanov · Pavel Batanov · commit 64084956a5d5 · 2016-03-03T10:38:22.000+03:00
diff --git a/RabbitMq/BaseConsumer.php b/RabbitMq/BaseConsumer.php
@@ -2,6 +2,8 @@
 
 namespace OldSound\RabbitMqBundle\RabbitMq;
 
+use PhpAmqpLib\Message\AMQPMessage;
+
 abstract class BaseConsumer extends BaseAmqp implements DequeuerInterface
 {
     protected $target;
@@ -43,6 +45,8 @@ protected function setupConsumer()
         $this->getChannel()->basic_consume($this->queueOptions['name'], $this->getConsumerTag(), false, false, false, false, array($this, 'processMessage'));
     }
 
+    public function processMessage(AMQPMessage $msg) {}
+
     protected function maybeStopConsumer()
     {
         if (extension_loaded('pcntl') && (defined('AMQP_WITHOUT_SIGNALS') ? !AMQP_WITHOUT_SIGNALS : true)) {

Original file line number	Diff line number	Diff line change
`@@ -2,6 +2,8 @@`
`2`	`2`
`3`	`3`	`namespace OldSound\RabbitMqBundle\RabbitMq;`
`4`	`4`
	`5`	`+use PhpAmqpLib\Message\AMQPMessage;`
	`6`	`+`
`5`	`7`	`abstract class BaseConsumer extends BaseAmqp implements DequeuerInterface`
`6`	`8`	`{`
`7`	`9`	`protected $target;`
`@@ -43,6 +45,8 @@ protected function setupConsumer()`
`43`	`45`	`$this->getChannel()->basic_consume($this->queueOptions['name'], $this->getConsumerTag(), false, false, false, false, array($this, 'processMessage'));`
`44`	`46`	`}`
`45`	`47`
	`48`	`+ public function processMessage(AMQPMessage $msg) {}`
	`49`	`+`
`46`	`50`	`protected function maybeStopConsumer()`
`47`	`51`	`{`
`48`	`52`	`if (extension_loaded('pcntl') && (defined('AMQP_WITHOUT_SIGNALS') ? !AMQP_WITHOUT_SIGNALS : true)) {`