1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
<?php
namespace PhpAmqpLib\Tests\Unit\Connection;
use InvalidArgumentException;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PHPUnit\Framework\Attributes\Test;
use PHPUnit\Framework\TestCase;
class AMQPStreamConnectionTest extends TestCase
{
#[Test]
public function channel_rpc_timeout_should_be_invalid_if_greater_than_read_write_timeout(): void
{
$this->expectException(InvalidArgumentException::class);
$this->expectExceptionMessage('channel RPC timeout must not be greater than I/O read-write timeout');
new AMQPStreamConnection(
HOST,
PORT,
USER,
PASS,
VHOST,
false,
'AMQPLAIN',
null,
'en_US',
3.0,
3.0,
null,
false,
0,
5.0
);
}
/**
* Generate deprecation warning if ssl_protocol is set
*/
#[Test]
public function trigger_deprecation_is_ssl_protocol_set(): void
{
$deprecationMessage = '';
$deprecationCode = '';
set_error_handler(
static function ($errno, $errstr) use (&$deprecationMessage, &$deprecationCode) {
$deprecationMessage = $errstr;
$deprecationCode = $errno;
},
E_USER_DEPRECATED
);
new AMQPStreamConnection(
HOST,
PORT,
USER,
PASS,
VHOST,
false,
'AMQPLAIN',
null,
'en_US',
3.0,
3.0,
null,
false,
0,
3.0,
'test_ssl_protocol'
);
restore_error_handler();
$this->assertEquals(E_USER_DEPRECATED, $deprecationCode);
$this->assertEquals('$ssl_protocol parameter is deprecated, use stream_context_set_option($context, \'ssl\', \'crypto_method\', $ssl_protocol) instead (see https://www.php.net/manual/en/function.stream-socket-enable-crypto.php for possible values)', $deprecationMessage);
}
}
|
