We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f618952 commit 08fb719Copy full SHA for 08fb719
src/Codeception/Module/AMQP.php
@@ -114,12 +114,12 @@ public function _before(\Codeception\TestCase $test)
114
* @param $exchange
115
* @param $message string|AMQPMessage
116
*/
117
- public function pushToExchange($exchange, $message)
+ public function pushToExchange($exchange, $message, $routing_key)
118
{
119
$message = $message instanceof AMQPMessage
120
? $message
121
: new AMQPMessage($message);
122
- $this->connection->channel()->basic_publish($message, $exchange);
+ $this->connection->channel()->basic_publish($message, $exchange, $routing_key);
123
}
124
125
/**
@@ -201,4 +201,4 @@ protected function cleanup()
201
202
203
204
-}
+}
0 commit comments