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
| <?php
| namespace PhpAmqpLib\Connection;
|
| use PhpAmqpLib\Wire\IO\StreamIO;
|
| class AMQPStreamConnection extends AbstractConnection
| {
| /**
| * @param string $host
| * @param string $port
| * @param string $user
| * @param string $password
| * @param string $vhost
| * @param bool $insist
| * @param string $login_method
| * @param null $login_response
| * @param string $locale
| * @param float $connection_timeout
| * @param float $read_write_timeout
| * @param null $context
| * @param bool $keepalive
| * @param int $heartbeat
| */
| public function __construct(
| $host,
| $port,
| $user,
| $password,
| $vhost = '/',
| $insist = false,
| $login_method = 'AMQPLAIN',
| $login_response = null,
| $locale = 'en_US',
| $connection_timeout = 3.0,
| $read_write_timeout = 3.0,
| $context = null,
| $keepalive = false,
| $heartbeat = 0
| ) {
| $io = new StreamIO(
| $host,
| $port,
| $connection_timeout,
| $read_write_timeout,
| $context,
| $keepalive,
| $heartbeat
| );
|
| parent::__construct(
| $user,
| $password,
| $vhost,
| $insist,
| $login_method,
| $login_response,
| $locale,
| $io,
| $heartbeat
| );
|
| // save the params for the use of __clone, this will overwrite the parent
| $this->construct_params = func_get_args();
| }
| }
|
|
