skolodyazhnyy /
butter-amqplib
| @@ 187-200 (lines=14) @@ | ||
| 184 | } |
|
| 185 | ||
| 186 | if ($class === "\x00\x28") { |
|
| 187 | if ($method === "\x00\x0A") { |
|
| 188 | return new Method\ExchangeDeclare( |
|
| 189 | $header['channel'], |
|
| 190 | Value\ShortValue::decode($data), |
|
| 191 | Value\ShortStringValue::decode($data), |
|
| 192 | Value\ShortStringValue::decode($data), |
|
| 193 | (bool) ($flags = Value\OctetValue::decode($data)) & 1, |
|
| 194 | (bool) $flags & 2, |
|
| 195 | (bool) $flags & 4, |
|
| 196 | (bool) $flags & 8, |
|
| 197 | (bool) $flags & 16, |
|
| 198 | Value\TableValue::decode($data) |
|
| 199 | ); |
|
| 200 | } |
|
| 201 | if ($method === "\x00\x0B") { |
|
| 202 | return new Method\ExchangeDeclareOk( |
|
| 203 | $header['channel'] |
|
| @@ 255-267 (lines=13) @@ | ||
| 252 | } |
|
| 253 | ||
| 254 | if ($class === "\x00\x32") { |
|
| 255 | if ($method === "\x00\x0A") { |
|
| 256 | return new Method\QueueDeclare( |
|
| 257 | $header['channel'], |
|
| 258 | Value\ShortValue::decode($data), |
|
| 259 | Value\ShortStringValue::decode($data), |
|
| 260 | (bool) ($flags = Value\OctetValue::decode($data)) & 1, |
|
| 261 | (bool) $flags & 2, |
|
| 262 | (bool) $flags & 4, |
|
| 263 | (bool) $flags & 8, |
|
| 264 | (bool) $flags & 16, |
|
| 265 | Value\TableValue::decode($data) |
|
| 266 | ); |
|
| 267 | } |
|
| 268 | if ($method === "\x00\x0B") { |
|
| 269 | return new Method\QueueDeclareOk( |
|
| 270 | $header['channel'], |
|
| @@ 353-365 (lines=13) @@ | ||
| 350 | $header['channel'] |
|
| 351 | ); |
|
| 352 | } |
|
| 353 | if ($method === "\x00\x14") { |
|
| 354 | return new Method\BasicConsume( |
|
| 355 | $header['channel'], |
|
| 356 | Value\ShortValue::decode($data), |
|
| 357 | Value\ShortStringValue::decode($data), |
|
| 358 | Value\ShortStringValue::decode($data), |
|
| 359 | (bool) ($flags = Value\OctetValue::decode($data)) & 1, |
|
| 360 | (bool) $flags & 2, |
|
| 361 | (bool) $flags & 4, |
|
| 362 | (bool) $flags & 8, |
|
| 363 | Value\TableValue::decode($data) |
|
| 364 | ); |
|
| 365 | } |
|
| 366 | if ($method === "\x00\x15") { |
|
| 367 | return new Method\BasicConsumeOk( |
|
| 368 | $header['channel'], |
|
