merged with stable branch

Author: DavertMik

src/Codeception/Module/AMQP.php

@@ -100,24 +100,27 @@ public function _before(\Codeception\TestCase $test)
     }
 
     /**
-     * Sends message to exchange
-     *
+     * Sends message to exchange by sending exchange name, message
+     * and (optionally) a routing key
+     * 
      * ``` php
      * <?php
      * $I->pushToExchange('exchange.emails', 'thanks');
      * $I->pushToExchange('exchange.emails', new AMQPMessage('Thanks!'));
+     * $I->pushToExchange('exchange.emails', new AMQPMessage('Thanks!'), 'severity');
      * ?>
      * ```
      *
      * @param $exchange
      * @param $message string|AMQPMessage
+     * @param $routing_key
      */
-    public function pushToExchange($exchange, $message)
+    public function pushToExchange($exchange, $message, $routing_key = null)
     {
         $message = $message instanceof AMQPMessage
             ? $message
             : new AMQPMessage($message);
-        $this->connection->channel()->basic_publish($message, $exchange);
+        $this->connection->channel()->basic_publish($message, $exchange, $routing_key);
     }
 
     /**
@@ -205,4 +208,4 @@ protected function cleanup()
             }
         }
     }
-}
+}