| @@ 226-234 (lines=9) @@ | ||
| 223 | } |
|
| 224 | if ($class === 30) { |
|
| 225 | // method "access.request-ok" |
|
| 226 | if ($method === 11) { |
|
| 227 | $frame = new Access\AccessRequestOkFrame(); |
|
| 228 | ||
| 229 | // consume "reserved1" (short) |
|
| 230 | list(, $frame->reserved1) = \unpack('n', $this->buffer); |
|
| 231 | $this->buffer = \substr($this->buffer, 2); |
|
| 232 | ||
| 233 | return $frame; |
|
| 234 | } |
|
| 235 | ||
| 236 | throw new AMQPProtocolException( |
|
| 237 | 'Frame method (' . $method . ') is invalid for class "access".' |
|
| @@ 295-305 (lines=11) @@ | ||
| 292 | ||
| 293 | // method "queue.purge-ok" |
|
| 294 | } |
|
| 295 | if ($method === 31) { |
|
| 296 | $frame = new Queue\QueuePurgeOkFrame(); |
|
| 297 | ||
| 298 | // consume "messageCount" (long) |
|
| 299 | list(, $frame->messageCount) = \unpack('N', $this->buffer); |
|
| 300 | $this->buffer = \substr($this->buffer, 4); |
|
| 301 | ||
| 302 | return $frame; |
|
| 303 | ||
| 304 | // method "queue.delete-ok" |
|
| 305 | } |
|
| 306 | if ($method === 41) { |
|
| 307 | $frame = new Queue\QueueDeleteOkFrame(); |
|
| 308 | ||
| @@ 306-316 (lines=11) @@ | ||
| 303 | ||
| 304 | // method "queue.delete-ok" |
|
| 305 | } |
|
| 306 | if ($method === 41) { |
|
| 307 | $frame = new Queue\QueueDeleteOkFrame(); |
|
| 308 | ||
| 309 | // consume "messageCount" (long) |
|
| 310 | list(, $frame->messageCount) = \unpack('N', $this->buffer); |
|
| 311 | $this->buffer = \substr($this->buffer, 4); |
|
| 312 | ||
| 313 | return $frame; |
|
| 314 | ||
| 315 | // method "queue.unbind-ok" |
|
| 316 | } |
|
| 317 | if ($method === 51) { |
|
| 318 | return new Queue\QueueUnbindOkFrame(); |
|
| 319 | } |
|