publish message with custom queue options : update ConnectionTest

This commit is contained in:
fedor.f 2019-02-13 14:53:10 +02:00
parent 6f9fdaf7e4
commit 4532319520

View File

@ -237,10 +237,10 @@ class ConnectionTest extends TestCase
public function testPublishWithQueueOptions() public function testPublishWithQueueOptions()
{ {
$factory = new TestAmqpFactory( $factory = new TestAmqpFactory(
$amqpConnection = $this->getMockBuilder(\AMQPConnection::class)->disableOriginalConstructor()->getMock(), $amqpConnection = $this->createMock(\AMQPConnection::class),
$amqpChannel = $this->getMockBuilder(\AMQPChannel::class)->disableOriginalConstructor()->getMock(), $amqpChannel = $this->createMock(\AMQPChannel::class),
$amqpQueue = $this->getMockBuilder(\AMQPQueue::class)->disableOriginalConstructor()->getMock(), $amqpQueue = $this->createMock(\AMQPQueue::class),
$amqpExchange = $this->getMockBuilder(\AMQPExchange::class)->disableOriginalConstructor()->getMock() $amqpExchange = $this->createMock(\AMQPExchange::class)
); );
$headers = [ $headers = [
'type' => '*', 'type' => '*',