PHPDaemon/Clients/AMQP/Driver/Protocol/v091/Protocol/Basic/BasicRecoverFrame.php 1 location
|
@@ 13-32 (lines=20) @@
|
10 |
|
* @author Aleksey I. Kuleshov YOU GLOBAL LIMITED |
11 |
|
* @package PHPDaemon\Clients\AMQP\Driver\Protocol\v091\Protocol\Basic |
12 |
|
*/ |
13 |
|
class BasicRecoverFrame implements MethodFrame, OutgoingFrame |
14 |
|
{ |
15 |
|
const METHOD_ID = 0x003c006e; |
16 |
|
|
17 |
|
public $frameChannelId = 0; |
18 |
|
public $requeue = false; // bit |
19 |
|
|
20 |
|
public static function create( |
21 |
|
$requeue = null |
22 |
|
) |
23 |
|
{ |
24 |
|
$frame = new self(); |
25 |
|
|
26 |
|
if (null !== $requeue) { |
27 |
|
$frame->requeue = $requeue; |
28 |
|
} |
29 |
|
|
30 |
|
return $frame; |
31 |
|
} |
32 |
|
} |
33 |
|
|
PHPDaemon/Clients/AMQP/Driver/Protocol/v091/Protocol/Confirm/ConfirmSelectFrame.php 1 location
|
@@ 13-32 (lines=20) @@
|
10 |
|
* @author Aleksey I. Kuleshov YOU GLOBAL LIMITED |
11 |
|
* @package PHPDaemon\Clients\AMQP\Driver\Protocol\v091\Protocol\Confirm |
12 |
|
*/ |
13 |
|
class ConfirmSelectFrame implements MethodFrame, OutgoingFrame |
14 |
|
{ |
15 |
|
const METHOD_ID = 0x0055000a; |
16 |
|
|
17 |
|
public $frameChannelId = 0; |
18 |
|
public $nowait = false; // bit |
19 |
|
|
20 |
|
public static function create( |
21 |
|
$nowait = null |
22 |
|
) |
23 |
|
{ |
24 |
|
$frame = new self(); |
25 |
|
|
26 |
|
if (null !== $nowait) { |
27 |
|
$frame->nowait = $nowait; |
28 |
|
} |
29 |
|
|
30 |
|
return $frame; |
31 |
|
} |
32 |
|
} |
33 |
|
|
PHPDaemon/Clients/AMQP/Driver/Protocol/v091/Protocol/Connection/ConnectionSecureOkFrame.php 1 location
|
@@ 13-32 (lines=20) @@
|
10 |
|
* @author Aleksey I. Kuleshov YOU GLOBAL LIMITED |
11 |
|
* @package PHPDaemon\Clients\AMQP\Driver\Protocol\v091\Protocol\Connection |
12 |
|
*/ |
13 |
|
class ConnectionSecureOkFrame implements MethodFrame, OutgoingFrame |
14 |
|
{ |
15 |
|
const METHOD_ID = 0x000a0015; |
16 |
|
|
17 |
|
public $frameChannelId = 0; |
18 |
|
public $response; // longstr |
19 |
|
|
20 |
|
public static function create( |
21 |
|
$response = null |
22 |
|
) |
23 |
|
{ |
24 |
|
$frame = new self(); |
25 |
|
|
26 |
|
if (null !== $response) { |
27 |
|
$frame->response = $response; |
28 |
|
} |
29 |
|
|
30 |
|
return $frame; |
31 |
|
} |
32 |
|
} |
33 |
|
|