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 |
|
|