@@ 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 = mb_orig_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 = mb_orig_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 = mb_orig_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 | } |