update test case for custom queue options
This commit is contained in:
parent
4532319520
commit
5e16053c70
@ -246,9 +246,9 @@ class ConnectionTest extends TestCase
|
|||||||
'type' => '*',
|
'type' => '*',
|
||||||
];
|
];
|
||||||
$amqpExchange->expects($this->once())->method('publish')
|
$amqpExchange->expects($this->once())->method('publish')
|
||||||
->with('body', null, 1, ['delivery_mode' => 2, 'headers' => $headers]);
|
->with('body', null, 1, ['delivery_mode' => 2, 'headers' => ['token' => 'uuid', 'type' => '*']]);
|
||||||
|
|
||||||
$connection = Connection::fromDsn('amqp://localhost/%2f/messages?queue[attributes][delivery_mode]=2&queue[flags]=1', [], true, $factory);
|
$connection = Connection::fromDsn('amqp://localhost/%2f/messages?queue[attributes][delivery_mode]=2&queue[attributes][headers][token]=uuid&queue[flags]=1', [], true, $factory);
|
||||||
$connection->publish('body', $headers);
|
$connection->publish('body', $headers);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user