skolodyazhnyy /
butter-amqplib
| @@ 321-330 (lines=10) @@ | ||
| 318 | Value\LongValue::decode($data) |
|
| 319 | ); |
|
| 320 | } |
|
| 321 | if ($method === "\x00\x28") { |
|
| 322 | return new Method\QueueDelete( |
|
| 323 | $header['channel'], |
|
| 324 | Value\ShortValue::decode($data), |
|
| 325 | Value\ShortStringValue::decode($data), |
|
| 326 | (bool) ($flags = Value\OctetValue::decode($data)) & 1, |
|
| 327 | (bool) $flags & 2, |
|
| 328 | (bool) $flags & 4 |
|
| 329 | ); |
|
| 330 | } |
|
| 331 | if ($method === "\x00\x29") { |
|
| 332 | return new Method\QueueDeleteOk( |
|
| 333 | $header['channel'], |
|
| @@ 385-394 (lines=10) @@ | ||
| 382 | Value\ShortStringValue::decode($data) |
|
| 383 | ); |
|
| 384 | } |
|
| 385 | if ($method === "\x00\x28") { |
|
| 386 | return new Method\BasicPublish( |
|
| 387 | $header['channel'], |
|
| 388 | Value\ShortValue::decode($data), |
|
| 389 | Value\ShortStringValue::decode($data), |
|
| 390 | Value\ShortStringValue::decode($data), |
|
| 391 | (bool) ($flags = Value\OctetValue::decode($data)) & 1, |
|
| 392 | (bool) $flags & 2 |
|
| 393 | ); |
|
| 394 | } |
|
| 395 | if ($method === "\x00\x32") { |
|
| 396 | return new Method\BasicReturn( |
|
| 397 | $header['channel'], |
|
